You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@activemq.apache.org by "Pradeep G (JIRA)" <ji...@apache.org> on 2009/07/24 12:25:33 UTC
[jira] Created: (AMQ-2331) Message is sent to wrong broker
Message is sent to wrong broker
-------------------------------
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: Critical
I have network of brokers configured in Hub/Spoke topology. The Spokes are 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. The Hub transmits messages by setting the message selector to the Spoke ID.
The issue am facing is as follows. 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 ?
Thanks,
Pradeep
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
[jira] Updated: (AMQ-2331) Message is sent to wrong broker in
network of brokers inspite of using the Message selector
Posted by "Pradeep G (JIRA)" <ji...@apache.org>.
[ 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.
[jira] Updated: (AMQ-2331) Message is sent to wrong broker
Posted by "Pradeep G (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/activemq/browse/AMQ-2331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Pradeep G updated AMQ-2331:
---------------------------
Description:
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
was:
I have network of brokers configured in Hub/Spoke topology. The Spokes are 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. The Hub transmits messages by setting the message selector to the Spoke ID.
The issue am facing is as follows. 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 ?
Thanks,
Pradeep
> Message is sent to wrong broker
> -------------------------------
>
> 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: Critical
>
> 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.
[jira] Resolved: (AMQ-2331) Message is sent to wrong broker in
network of brokers inspite of using the Message selector
Posted by "Gary Tully (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/activemq/browse/AMQ-2331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Gary Tully resolved AMQ-2331.
-----------------------------
Resolution: Duplicate
Assignee: Gary Tully
> 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
> Assignee: Gary Tully
> Priority: Blocker
> Fix For: 5.3.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.
[jira] Updated: (AMQ-2331) Message is sent to wrong broker in
network of brokers inspite of using the Message selector
Posted by "Gary Tully (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/activemq/browse/AMQ-2331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Gary Tully updated AMQ-2331:
----------------------------
Fix Version/s: (was: 5.2.0)
5.3.0
> 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.3.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.
[jira] Updated: (AMQ-2331) Message is sent to wrong broker in
network of brokers inspite of using the Message selector
Posted by "Pradeep G (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/activemq/browse/AMQ-2331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Pradeep G updated AMQ-2331:
---------------------------
Summary: Message is sent to wrong broker in network of brokers inspite of using the Message selector (was: Message is sent to wrong broker)
> 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: Critical
>
> 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.
[jira] Commented: (AMQ-2331) Message is sent to wrong broker in
network of brokers inspite of using the Message selector
Posted by "Gary Tully (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/activemq/browse/AMQ-2331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=52944#action_52944 ]
Gary Tully commented on AMQ-2331:
---------------------------------
can you try this with a 5.3-SNAPSHOT and with conduitSubscriptions disabled. I recall a fix related to selectors and networks in the past few months.
> 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.
[jira] Commented: (AMQ-2331) Message is sent to wrong broker in
network of brokers inspite of using the Message selector
Posted by "Gary Tully (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/activemq/browse/AMQ-2331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=52992#action_52992 ]
Gary Tully commented on AMQ-2331:
---------------------------------
I would hope to cut a first release candidate towards the end of next week but the process may take a little longer. There are still a bunch of issues that need to be resolved or deferred.
To see the relevant patch checkout the subversion commits attached to the issue: https://issues.apache.org/activemq/browse/AMQ-2104?page=com.atlassian.jira.plugin.ext.subversion%3Asubversion-commits-tabpanel
> 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.3.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.
[jira] Commented: (AMQ-2331) Message is sent to wrong broker in
network of brokers inspite of using the Message selector
Posted by "Pradeep G (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/activemq/browse/AMQ-2331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=52988#action_52988 ]
Pradeep G commented on AMQ-2331:
--------------------------------
Gary,
The 5.3 snapshot worked. When is the 5.3 release likely to happen ? If this is going to take a while (more than 2-3) weeks, can you provide us with a patch that I can use ?
Regards,
Pradeep.
> 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.