On 11/15/2011 08:46 PM, dmounessa wrote:
I am running C++ Broker with JAVA clients. I have one client that creates
four producer threads with topics of NODE0, NODE1, NODE2, NODE3 each of
these send a message.
Then I have one java client that consume messages from topic NODE0.
I am using the destination format amq.topic.
destination.NODE0 = amq.topic
destination.NODE1 = amq.topic
destination.NODE2 = amq.topic
destination.NODE3 = amq.topic
Why does the broker sends message from all producers to one consumer. I know
if I use Queue I can send from NODE0 producer to NODE0 consumer. But what do
I need to do so this also works. Is this in the Address Format or broker
configuration?
Assuming I understand you correctly this time, you can create four
separate exchanges and use the names for them in place of amq.topic above.
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]