Hi
we have activemq brokers(5.17.4) distributed over network as below
[cid:image003.jpg@01D9567B.58F0C300]
And we are using JDBC master slave(MS-SQL) configuration, in each node the
network bridge is established as follows with other nodes.
<networkConnector name="ntwrk_node2"
userName="admin"
password="admin"
uri="masterslave:(ssl://amq-node2-m:61617,ssl://amq-node2-s:61617)"
networkTTL="3"
conduitSubscriptions="true"
decreaseNetworkConsumerPriority="true"
suppressDuplicateQueueSubscriptions="true"
duplex="false"/>
Note: the above snippet is just a sample of network bridge to node2 in node1
master broker.
When the message starts appearing in the queue we are seeing lot of DLQ message
queues for each queue as follows, this is stacking up and the size is growing
more than 10k
[cid:image006.jpg@01D9567B.58F0C300]
A sample message in DLQ
Unknown message type [org.apache.activemq.command.ActiveMQMessage]
ActiveMQMessage {commandId = 0, responseRequired = false, messageId =
ID:amq-uat-node2-40758-1678741411100-3:1:0:0:10710, originalDestination =
topic://ActiveMQ.Advisory.Consumer.Queue.Consumer.TEST.QUEUE,
originalTransactionId = null, producerId =
ID:amq-uat-node2-40758-1678741411100-3:1:0:0, destination =
queue://DLQ.ActiveMQ.Advisory.Consumer.Queue.Consumer.TEST.QUEUE, transactionId
= null, expiration = 0, timestamp = 0, arrival = 0, brokerInTime =
1678746285934, brokerOutTime = 1678754625959, correlationId = null, replyTo =
null, persistent = true, type = Advisory, priority = 0, groupID = null,
groupSequence = 0, targetConsumerId = null, compressed = false, userID = null,
content = null, marshalledProperties =
org.apache.activemq.util.ByteSequence@22682f3e<mailto:org.apache.activemq.util.ByteSequence@22682f3e>,
dataStructure = ConsumerInfo {commandId = 1375, responseRequired = false,
consumerId = amq-uat-node2->amq-uat-node3-40758-1678741411100-21:1:1:1044,
destination = queue://Consumer.TEST.QUEUE, prefetchSize = 1000,
maximumPendingMessageLimit = 0, browser = false, dispatchAsync = true, selector
= null, clientId = ID:7f8df9efea1b-45615-1678743564602-2:1, subscriptionName =
null, noLocal = false, exclusive = false, retroactive = false, priority = -9,
brokerPath = [amq-uat-node1, amq-uat-node4, amq-uat-node3],
optimizedAcknowledge = false, noRangeAcks = false, additionalPredicate =
org.apache.activemq.network.ConditionalNetworkBridgeFilterFactory$ConditionalNetworkBridgeFilter@3ec92a65<mailto:org.apache.activemq.network.ConditionalNetworkBridgeFilterFactory$ConditionalNetworkBridgeFilter@3ec92a65>,
networkConsumerIds = [ID:7f8df9efea1b-45615-1678743564602-3:1:83:1,
amq-uat-node4->amq-uat-node1-43064-1678741392300-20:1:1:618,
amq-uat-node3->amq-uat-node4-45494-1678741514245-9:1:1:392]}, redeliveryCounter
= 0, size = 1024, properties = {originBrokerURL=vm://amq-uat-node2,
consumerCount=3, originBrokerId=amq-uat-node2,
dlqDeliveryFailureCause=java.lang.Throwable: TopicSubDiscard.
ID:amq-uat-node3->amq-uat-node2-45494-1678741514245-10:2:1:1,
originalExpiration=0, originBrokerName=amq-uat-node2,
originalDeliveryMode=NON_PERSISTENT}, readOnlyProperties = true, readOnlyBody =
true, droppable = false, jmsXGroupFirstForConsumer = false}
Can you please help me in regards to how I can stop this message and the
possible reason behind this.
Kind Regards
--
Siva Teja / Software Consultant
Development and Integration
This e-mail message and any accompanying attachments may contain information
that is confidential and subject to legal privilege.
If you are not the intended recipient, do not read, use, disseminate,
distribute or copy this message or attachments.
If you have received this message in error, please notify the sender
immediately and delete this message.
