On 10/28/2010 09:44 AM, [email protected] wrote:
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);
try changing:
subscriptionsMgr->subscribe(listener, queue_name);
to:
subscriptionsMgr->subscribe(listener, queue_name,
SubscriptionSettings(FlowControl::messageWindow(1)));
Does that address the issue you are seeing?
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
