qpid-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Gordon Sim <g...@redhat.com>
Subject Re: LocalQueue get
Date Wed, 15 Jul 2009 13:16:05 GMT
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 <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
> 
> 
> 
> 
>       


---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project:      http://qpid.apache.org
Use/Interact: mailto:users-subscribe@qpid.apache.org


Mime
View raw message