Adam Chase wrote:
SubscriptionManager subscriptions(session); // Create a listener and subscribe it to the queue named "message_queue" Listener listener(subscriptions); // Receive messages until the subscription is cancelled // by Listener::received() LocalQueue lq; subscriptions.start(); subscriptions.setAutoStop(false); SubscriptionSettings settings; settings.completionMode = COMPLETE_ON_ACCEPT; settings.acceptMode = ACCEPT_MODE_EXPLICIT; settings.autoAck = 0; settings.flowControl = FlowControl::unlimited();Subscription sub1 = subscriptions.subscribe(lq, "message_queue", settings, "lq"); Message m = lq.pop(); sub1.cancel(); sleep(5); subscriptions.subscribe(listener, "message_queue", "listener"); subscriptions.wait(); When I do this I get no messages on my listener and subscriptions just exits. If I do a while(sleep) instead of the wait, I still never see my message. Even if I make 2 connections and 2 sessions and 2 subscriptionManagers and run them both I still don't see messages on the listener. Am I doing something wrong?
one brief clarification, you are not getting any messages when you re-subscribe. I.e you
get messages on the lq, but not on the listener? Carl. --------------------------------------------------------------------- Apache Qpid - AMQP Messaging Implementation Project: http://qpid.apache.org Use/Interact: mailto:[email protected]
