face the same problem when acuiremode is PRE_ACQUIRED settings.acquireMode = ACQUIRE_MODE_PRE_ACQUIRED; do i have to add session.sendCompletion after get ?? 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]
