I am using the example code examples/pub-sub/topic_listener.cpp. In this
code, it declares queue by adding a session id so different sessions will
have different queue names. If you change the code to use the same queue
name for different sessions, you will get the problem. The code looks
basically like below:
session.queueDeclare(arg::queue = queue_name, arg::exclusive = false,
arg::autoDelete = true, arg::durable = false);
session.exchangeBind(arg::exchange = exchange,
arg::queue = queue_name, arg::bindingKey = binding);
session.exchangeBind(arg::exchange = exchange,
arg::queue = queue_name, arg::bindingKey =
"control");
subscriptionsMgr = new SubscriptionManager(
session);
subscriptionsMgr->subscribe(listener, queue_name);
--
View this message in context:
http://apache-qpid-users.2158936.n2.nabble.com/Publish-Subscribe-queue-question-tp5673932p5681763.html
Sent from the Apache Qpid users mailing list archive at Nabble.com.
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
