[
https://issues.apache.org/activemq/browse/AMQ-2331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pradeep G updated AMQ-2331:
---------------------------
Fix Version/s: 5.2.0
Priority: Blocker (was: Critical)
> Message is sent to wrong broker in network of brokers inspite of using the
> Message selector
> -------------------------------------------------------------------------------------------
>
> Key: AMQ-2331
> URL: https://issues.apache.org/activemq/browse/AMQ-2331
> Project: ActiveMQ
> Issue Type: Bug
> Components: Broker, Connector, Selector
> Affects Versions: 5.2.0
> Environment: All
> Reporter: Pradeep G
> Priority: Blocker
> Fix For: 5.2.0
>
>
> I have a network of brokers configured in Hub/Spoke topology. The Spokes
> connect to the Hub via duplex network connector. Am using only Queues, and
> there are same set of Queues on both the Hub and the Spokes. Each of the
> Queues on the Spokes have only one consumer, and the consumer subscribes to
> messages based on a selector. The selector field is the Spoke ID (a simple
> name). The Hub transmits messages meant for a spoke by setting the message
> selector in the message to the Spoke ID. The idea is to send specific
> messages to the respective Spoke. So all the messages are sure to have the
> message selector set to the specific Spoke ID.
> The issue am facing is as follows. Suppose I have two Spokes A and B, and
> connect to a Hub say H via duplex network connector. Most times this setup
> works fine, but some times the messages meant for A are sent to B and
> vice-versa.
> Here is what I found in the logs:
> 2009-07-24 15:48:21,054 DEBUG [org.apache.activemq.store.amq.AMQMessageStore]
> [ActiveMQ Transport: tcp:///127.0.0.1:53209]: Journalled message add for:
> ID:pgopal-lt-53198-1248427143033-2:6:1:97:27, at: offset = 1032207, file = 1,
> size = 444, type = 1
> 2009-07-24 15:48:21,057 DEBUG [org.apache.activemq.store.amq.AMQMessageStore]
> [ActiveMQ Task]: Doing batch update... adding: 1 removing: 0
> 2009-07-24 15:48:21,057 DEBUG [org.apache.activemq.store.amq.AMQMessageStore]
> [ActiveMQ Task]: Batch update done.
> 2009-07-24 15:48:21,062 DEBUG [org.apache.activemq.store.amq.AMQMessageStore]
> [ActiveMQ Transport: tcp:///172.17.0.58:2673]: Journalled message remove for:
> ID:pgopal-lt-53198-1248427143033-2:6:1:97:27, at: offset = 1032651, file = 1,
> size = 285, type = 1
> 2009-07-24 15:48:21,062 DEBUG [org.apache.activemq.store.amq.AMQMessageStore]
> [ActiveMQ Task]: Doing batch update... adding: 0 removing: 1
> 2009-07-24 15:48:21,062 DEBUG [org.apache.activemq.store.amq.AMQMessageStore]
> [ActiveMQ Task]: Batch update done.
> The message was meant for a consumer in the broker running on machine
> 172.17.0.59, whereas the message is being removed from 172.17.0.58 (line 4).
> Is there a workaround or patch ?
> Thanks,
> Pradeep
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
