Nithesh Shetty wrote:
Hi,
I have created a thread where i
open connection to broker
and create a localqueue with the below configuration
SubscriptionManager subscriptions(session);
SubscriptionSettings settings;
settings.exclusive = false;
setting.flowControl = FlowControl::messageWindow(1);
settings.acceptMode = ACCEPT_MODE_EXPLICIT;
settings.acquireMode = ACQUIRE_MODE_NOT_ACQUIRED;
in the thread i have written a loop to get message
Message message;
for (int i = 0; i < 100; ++i)
{
localqueue.get(message, qpid::sys::TIME_INFINITE);
session.sendCompleted();
}
There are around 200 message in the queue, idealy it should get 100 messages
but it doesn't retrieve all the hundred message.
any change in the configuration.
Thanks in advance.
Regards,
Nithesh
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
