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]

Reply via email to