You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@activemq.apache.org by "Sergei (Jira)" <ji...@apache.org> on 2025/02/01 10:15:00 UTC

[jira] [Created] (AMQ-9655) Message stuck and is not transmitted to the same brocker twice

Sergei created AMQ-9655:
---------------------------

             Summary: Message stuck and is not transmitted to the same brocker twice
                 Key: AMQ-9655
                 URL: https://issues.apache.org/jira/browse/AMQ-9655
             Project: ActiveMQ Classic
          Issue Type: Bug
          Components: Broker
    Affects Versions: 5.18.6
         Environment: Apache ActiveMQ 5.18.6.

Red Hat Enterprise Linux Server release 7.6
            Reporter: Sergei


We have the following topology of 3 brokers:

{{b1}} -> {{b2}} <-> {{b3}}

Messages refuse to move from {{b3}} to {{b2}} after they were forwarded from {{b2}} to {{{}b3{}}}.

Configuration of the networkConnectors:
 * {{b1}} -> {{{}b2{}}}:

{noformat}
<networkConnector uri="static:(tcp://b2:61616?wireFormat.tightEncodingEnabled=false&amp;wireFormat.cacheEnabled=false)" name="bridge12" decreaseNetworkConsumerPriority="false" consumerTTL="2" messageTTL="100000"></networkConnector>{noformat}

 * {{b2}} <-> {{b3}} (duplex, configured on {{{}b3{}}})

{noformat}
<networkConnector uri="static:(tcp://b2:61616?wireFormat.tightEncodingEnabled=false&amp;wireFormat.cacheEnabled=false)" name="bridge32" decreaseNetworkConsumerPriority="false" consumerTTL="2" messageTTL="100000" duplex="true"></networkConnector>{noformat}

Steps to reproduce:
 # Start STOMP producer on {{b1}} to queue {{{}test{}}}.
 # Start STOMP consumer on {{b3}} from queue {{{}test{}}}. Consume messages slow enough, so that {{test}} queue length on {{b3}} is increasing.
 # Stop the producer, then stop the consumer. As the result you have empty queues {{test}} on {{b1}} and {{b2}} and non-empty queue on {{{}b3{}}}. Property {{BrokerPath}} of messages should contain something like "{{{}[ID:b1-xxx, ID:b2-xxx]{}}}" as the messages passed {{b1}} and {{{}b2{}}}. 
 # Start consumer on {{b2}} from queue {{{}test{}}}. Messages are not forwarded from {{b3}} to {{b2}} even though {{messageTTL}} is high enough.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@activemq.apache.org
For additional commands, e-mail: issues-help@activemq.apache.org
For further information, visit: https://activemq.apache.org/contact