Mailing-List: contact users-help@qpid.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@qpid.apache.org
Received-SPF: pass (athena.apache.org: domain of gsim@redhat.com designates
 66.187.233.31 as permitted sender)
Message-ID: <4A5B3822.4090104@redhat.com>
Date: Mon, 13 Jul 2009 14:35:30 +0100
From: Gordon Sim <gsim@redhat.com>
Organization: Registered Address: Red Hat UK Ltd, Amberley Place, 107-111
 Peascod Street, Windsor, Berkshire, SI4 1TE, United Kingdom.,Registered in
 England and Wales under Company Registration No. 3798903,Directors: Michael
 Cunningham (USA), Charlie Peters (USA) and David Owens (Ireland)
User-Agent: Thunderbird 1.5.0.2 (X11/20060501)
MIME-Version: 1.0
To: users@qpid.apache.org
Subject: Re: localqueue get
References: <25899.63527.qm@web46112.mail.sp1.yahoo.com>
In-Reply-To: <25899.63527.qm@web46112.mail.sp1.yahoo.com>
Content-Type: text/plain; charset=ISO-8859-1; format=flowed
Content-Transfer-Encoding: 7bit

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