You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@qpid.apache.org by David Zhou <da...@gmail.com> on 2010/07/14 09:28:28 UTC

remove all consumer sessions of a queue

Hi all,

my question is:
Is it possible to remove all consumer sessions of a queue?

It's C++ broker and python client I used.

when my apps crash and run into an unpredictable state, the thread that
listening to a queue is gone too.

For queue server, the listening session is still there since my apps have no
chance to call session.close() when crashing.

At first I try to delete the queue and recreate it again, but the queue
server seems to delete the queue when no session is subscribed to it.

If a producer sends a message to the queue, the queue server remove the
listening session after (approximately) 30 mins timeout period because
there's no ack back.

If it is not possible to remove sessions manually, is there any way to
configure the session timeout for queue server?

Thanks in advance.


-- 
View this message in context: http://apache-qpid-users.2158936.n2.nabble.com/remove-all-consumer-sessions-of-a-queue-tp5291358p5291358.html
Sent from the Apache Qpid users mailing list archive at Nabble.com.

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


Re: remove all consumer sessions of a queue

Posted by Gordon Sim <gs...@redhat.com>.
On 07/14/2010 08:28 AM, David Zhou wrote:
>
> Hi all,
>
> my question is:
> Is it possible to remove all consumer sessions of a queue?
>
> It's C++ broker and python client I used.
>
> when my apps crash and run into an unpredictable state, the thread that
> listening to a queue is gone too.
>
> For queue server, the listening session is still there since my apps have no
> chance to call session.close() when crashing.

Do you mean that management tools are showing the session still in 
existence? If so which version of the broker/client are you using?

If your client exits (abnormally or not) any connections and associated 
sessions should be automatically terminated on the broker.

>
> At first I try to delete the queue and recreate it again, but the queue
> server seems to delete the queue when no session is subscribed to it.
>
> If a producer sends a message to the queue, the queue server remove the
> listening session after (approximately) 30 mins timeout period because
> there's no ack back.
>
> If it is not possible to remove sessions manually, is there any way to
> configure the session timeout for queue server?
>
> Thanks in advance.
>
>


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