Nithesh Shetty wrote:
face the same problem when acuiremode is PRE_ACQUIRED
settings.acquireMode = ACQUIRE_MODE_PRE_ACQUIRED;
do i have to add session.sendCompletion after get ??
No, for pre-acquired messages the completion will be sent automatically
as those messages are auto-acked.
If you aren't seeing all the messages delivered in that mode it is
something else and you should turn on tracing (--log-enable trace) for
the broker to get some debug information.
Regards,
Nithesh
--- On Wed, 7/15/09, Gordon Sim <[email protected]> wrote:
From: Gordon Sim <[email protected]>
Subject: Re: LocalQueue get
To: [email protected]
Date: Wednesday, July 15, 2009, 1:05 PM
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]
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
