You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by "Siva Teja (healthAlliance)" <Si...@healthalliance.co.nz> on 2023/03/14 00:46:16 UTC
Messages in DLQ.ActiveMQ.Advisory are stacked up
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<ma...@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<ma...@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.
Re: Messages in DLQ.ActiveMQ.Advisory are stacked up
Posted by Justin Bertram <jb...@apache.org>.
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.Teja@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.
>
RE: Messages in DLQ.ActiveMQ.Advisory are stacked up
Posted by "Siva Teja (healthAlliance)" <Si...@healthalliance.co.nz>.
Attached the outlook item and hope it will have the images in it.
Thanks & Regards,
Siva Teja / Software Consultant
From: Siva Teja (healthAlliance)
Sent: Tuesday, 14 March 2023 1:46 pm
To: users@activemq.apache.org
Subject: Messages in DLQ.ActiveMQ.Advisory are stacked up
Hi
we have activemq brokers(5.17.4) distributed over network as below
[cid:image003.jpg@01D95690.2F6A3830]
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:image004.jpg@01D95690.2F6A3830]
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<ma...@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<ma...@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.