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 Mon, 13 Jul 2009 13:35:30 GMT
Nithesh Shetty wrote:
> hi,
>  
>  the listener sample has the following settings;
>  SubscriptionManager subscriptions(session);
>  SubscriptionSettings settings;
>  settings.acceptMode = ACCEPT_MODE_EXP;
>  settings.acquireMode = ACQUIRE_MODE_PRE_ACQUIRED;
>  LocalQueue local_queue;
>  subscriptions.subscribe(local_queue, "RMS", settings, "rmsset");
>   Message message = local_queue.get();
> 
>  
> before getting the message i put a breakpoint over here and i execute another exe to
get the message(timeout infinity) but it hangs  till the above code gets the message and closes
the connection.

Thats because the message has been acquired by the client that you have 
stopped.

Note also that with the local queue, the auto-acking behaviour is to 
accept the message before returning it. So after the get() above, the 
message will have been dequeued. If you don't want this you need to turn 
off auto-acking (e.g. settings.autoAck = 0) and handle issuing the 
accept yourself.

Further, as you are not using any flow control, the first client will 
likely have several other acquired (but unaccepted) messages in the 
local queue. If you want to avoid that set some flow control (e.g. 
settings.flowControl = FlowControl::messageWindow(1)).


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


Mime
View raw message