You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@qpid.apache.org by Lahiru Gunathilake <gl...@gmail.com> on 2010/11/01 06:15:08 UTC

Re: JMS Temporary Queue delete() doesn't

Hi Robbie,

Can you please tell me how are we managing temp queues in 0.6 release ? We
have a scenario like creating very large number of temp queues. How Qpid
cleanup temp queues ? can we define a global time to live value only for
temp queues ?

Or is there any other way for us to clean the temp queues ?

Regards
Lahiru

On Mon, May 31, 2010 at 11:06 PM, Robbie Gemmell
<ro...@gmail.com>wrote:

> There are a couple of Improvement and Bug JIRAs hanging around for this one
> already. The Java client is currently relying on the auto-delete nature of
> the created queue to clean up the queue on the broker when the session is
> closed, as you have noticed.
>
> Robbie
>
> > -----Original Message-----
> > From: Andrew Wright [mailto:atwright@mac.com]
> > Sent: 31 May 2010 17:36
> > To: users@qpid.apache.org
> > Subject: JMS Temporary Queue delete() doesn't
> >
> > Hi all,
> >
> > We've run into a small issue with temporary queues. In a nutshell -
> > calling temporaryQueue.delete() from a JMS app doesn't actually delete
> > the AMQP queue on the broker. Closing the session that originally
> > created the temp queue does remove it.
> >
> > Is this expected or does it sound like a bug? Should mention - MRG 1.2
> > C++ broker, qpid 0.6 java client libraries.
> >
> > Cheers,
> > Andrew
> >
> > ---------------------------------------------------------------------
> > 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
>
>

Re: JMS Temporary Queue delete() doesn't

Posted by Robbie Gemmell <ro...@gmail.com>.
On 1 November 2010 14:53, Lahiru Gunathilake <gl...@gmail.com> wrote:
> Hi Robbie,
>
> Thanks Robbie for your reply.
>
> In this scenario, Qpid creates unnecessary replyTo queues when we send
> messages to a particular queue. I simply want to delete those queues since
> this will be an issue with resource consumption.
>
> Robbie, can you please point me to the location where we create temp queues
> by assuming a IN/OUT message has come to Qpid.


Are you using the new addressing syntax? If so this behaviour may be
related to your address strings, however I have little experience with
the new addressing so I cant really help there.

Rajith?

> On Mon, Nov 1, 2010 at 6:00 PM, Robbie Gemmell <ro...@gmail.com>wrote:
>
>> Hi Lahiru,
>>
>> Currently I believe the temporary queues are only deleted when the
>> connection closes, although it mgiht be when the Session closes when
>> using the 0-10 protocol, which 0.6 does by default. You should be able
>> to easily test when they get deleted by using a test program which
>> closes the Session and/or Connection and then sleeps before
>> completing, and monitoring when the queue dissapears using management.
>>
>> TimeToLive can be set either on a MessageProducer or on the individual
>> Message objects before they are sent, there is currently no way to
>> assign it on the broker as far as I know.
>>
> I want to set a TTL value for a Queue not to a message actually ? Is that
> possible to define a TTL value for all the temporary queues ?
>

You mean a time after which the queue itself should be deleted? No,
there is currently no such capability in the client or the broker (and
im not sure how much sense there would be in doing so).

Expected behaviour is for TemporaryQueue's (created by
session.createTemporaryQueue() ) to be deleted by the broker when the
connection which created them goes away. If there are unnamed
'temporary' queues being created by means other than
createTemporaryQueue() (again, new addressing syntax perhaps ?) then I
guess its possible there is a defect with their deletion when
connections are closed.

If you could give more specific details (perhaps code samples?) of
what you are doing then perhaps someone can help.

> Thanks
> Lahiru
>
>>
>> Robbie
>>
>> On 1 November 2010 05:15, Lahiru Gunathilake <gl...@gmail.com> wrote:
>> > Hi Robbie,
>> >
>> > Can you please tell me how are we managing temp queues in 0.6 release ?
>> We
>> > have a scenario like creating very large number of temp queues. How Qpid
>> > cleanup temp queues ? can we define a global time to live value only for
>> > temp queues ?
>> >
>> > Or is there any other way for us to clean the temp queues ?
>> >
>> > Regards
>> > Lahiru
>> >

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


Re: JMS Temporary Queue delete() doesn't

Posted by Lahiru Gunathilake <gl...@gmail.com>.
Hi Robbie,

Thanks Robbie for your reply.

In this scenario, Qpid creates unnecessary replyTo queues when we send
messages to a particular queue. I simply want to delete those queues since
this will be an issue with resource consumption.

Robbie, can you please point me to the location where we create temp queues
by assuming a IN/OUT message has come to Qpid.
On Mon, Nov 1, 2010 at 6:00 PM, Robbie Gemmell <ro...@gmail.com>wrote:

> Hi Lahiru,
>
> Currently I believe the temporary queues are only deleted when the
> connection closes, although it mgiht be when the Session closes when
> using the 0-10 protocol, which 0.6 does by default. You should be able
> to easily test when they get deleted by using a test program which
> closes the Session and/or Connection and then sleeps before
> completing, and monitoring when the queue dissapears using management.
>
> TimeToLive can be set either on a MessageProducer or on the individual
> Message objects before they are sent, there is currently no way to
> assign it on the broker as far as I know.
>
I want to set a TTL value for a Queue not to a message actually ? Is that
possible to define a TTL value for all the temporary queues ?

Thanks
Lahiru

>
> Robbie
>
> On 1 November 2010 05:15, Lahiru Gunathilake <gl...@gmail.com> wrote:
> > Hi Robbie,
> >
> > Can you please tell me how are we managing temp queues in 0.6 release ?
> We
> > have a scenario like creating very large number of temp queues. How Qpid
> > cleanup temp queues ? can we define a global time to live value only for
> > temp queues ?
> >
> > Or is there any other way for us to clean the temp queues ?
> >
> > Regards
> > Lahiru
> >
> > On Mon, May 31, 2010 at 11:06 PM, Robbie Gemmell
> > <ro...@gmail.com>wrote:
> >
> >> There are a couple of Improvement and Bug JIRAs hanging around for this
> one
> >> already. The Java client is currently relying on the auto-delete nature
> of
> >> the created queue to clean up the queue on the broker when the session
> is
> >> closed, as you have noticed.
> >>
> >> Robbie
> >>
> >> > -----Original Message-----
> >> > From: Andrew Wright [mailto:atwright@mac.com]
> >> > Sent: 31 May 2010 17:36
> >> > To: users@qpid.apache.org
> >> > Subject: JMS Temporary Queue delete() doesn't
> >> >
> >> > Hi all,
> >> >
> >> > We've run into a small issue with temporary queues. In a nutshell -
> >> > calling temporaryQueue.delete() from a JMS app doesn't actually delete
> >> > the AMQP queue on the broker. Closing the session that originally
> >> > created the temp queue does remove it.
> >> >
> >> > Is this expected or does it sound like a bug? Should mention - MRG 1.2
> >> > C++ broker, qpid 0.6 java client libraries.
> >> >
> >> > Cheers,
> >> > Andrew
> >> >
> >> > ---------------------------------------------------------------------
> >> > 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
> >>
> >>
> >
>
> ---------------------------------------------------------------------
> Apache Qpid - AMQP Messaging Implementation
> Project:      http://qpid.apache.org
> Use/Interact: mailto:users-subscribe@qpid.apache.org
>
>

Re: JMS Temporary Queue delete() doesn't

Posted by Robbie Gemmell <ro...@gmail.com>.
Hi Lahiru,

Currently I believe the temporary queues are only deleted when the
connection closes, although it mgiht be when the Session closes when
using the 0-10 protocol, which 0.6 does by default. You should be able
to easily test when they get deleted by using a test program which
closes the Session and/or Connection and then sleeps before
completing, and monitoring when the queue dissapears using management.

TimeToLive can be set either on a MessageProducer or on the individual
Message objects before they are sent, there is currently no way to
assign it on the broker as far as I know.

Robbie

On 1 November 2010 05:15, Lahiru Gunathilake <gl...@gmail.com> wrote:
> Hi Robbie,
>
> Can you please tell me how are we managing temp queues in 0.6 release ? We
> have a scenario like creating very large number of temp queues. How Qpid
> cleanup temp queues ? can we define a global time to live value only for
> temp queues ?
>
> Or is there any other way for us to clean the temp queues ?
>
> Regards
> Lahiru
>
> On Mon, May 31, 2010 at 11:06 PM, Robbie Gemmell
> <ro...@gmail.com>wrote:
>
>> There are a couple of Improvement and Bug JIRAs hanging around for this one
>> already. The Java client is currently relying on the auto-delete nature of
>> the created queue to clean up the queue on the broker when the session is
>> closed, as you have noticed.
>>
>> Robbie
>>
>> > -----Original Message-----
>> > From: Andrew Wright [mailto:atwright@mac.com]
>> > Sent: 31 May 2010 17:36
>> > To: users@qpid.apache.org
>> > Subject: JMS Temporary Queue delete() doesn't
>> >
>> > Hi all,
>> >
>> > We've run into a small issue with temporary queues. In a nutshell -
>> > calling temporaryQueue.delete() from a JMS app doesn't actually delete
>> > the AMQP queue on the broker. Closing the session that originally
>> > created the temp queue does remove it.
>> >
>> > Is this expected or does it sound like a bug? Should mention - MRG 1.2
>> > C++ broker, qpid 0.6 java client libraries.
>> >
>> > Cheers,
>> > Andrew
>> >
>> > ---------------------------------------------------------------------
>> > 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
>>
>>
>

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