qpid-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Nithesh Shetty <knitheshshe...@yahoo.com>
Subject Re: LocalQueue get
Date Wed, 15 Jul 2009 13:02:20 GMT
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 <gsim@redhat.com> wrote:


From: Gordon Sim <gsim@redhat.com>
Subject: Re: LocalQueue get
To: users@qpid.apache.org
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:users-subscribe@qpid.apache.org




      
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message