[
https://issues.apache.org/jira/browse/AMQ-9655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jean-Baptiste Onofré reassigned AMQ-9655:
-----------------------------------------
Assignee: Jean-Baptiste Onofré
> 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
> Assignee: Jean-Baptiste Onofré
> Priority: Minor
>
> 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&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&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: [email protected]
For additional commands, e-mail: [email protected]
For further information, visit: https://activemq.apache.org/contact
