For what it's worth neither of your attached images made it through to the list. See here [1].
Justin [1] https://lists.apache.org/thread/pgtxoj2v334ffmvh3sfxcnhnv87028zh On Mon, Mar 13, 2023 at 7:47 PM Siva Teja (healthAlliance) < siva.t...@healthalliance.co.nz> wrote: > Hi > > > > we have activemq brokers(5.17.4) distributed over network as below > > > > 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 > > > > 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, 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, > 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. >
