Actually, my facts were wrong, I apologize ! Before doing a queue.delete, I did a message.cancel. Sorry about that.
So to be clear, here what I did : 1) Create a queue 2) listen for any incoming messages 3) message.cancel 4) queue.delete <= here the queue doesn't exist anymore and it throws an exception => I wasn't aware that message.Cancel would delete the queue (which was by the way configured as auto-delete) -----Message d'origine----- De : Gordon Sim [mailto:[email protected]] Envoyé : mardi 28 juillet 2009 18:22 À : [email protected] Objet : Re: Queue.Delete with Qpid 0.5 +> Queue Not Found Julien Lavigne du Cadet wrote: > "Is it possible that the queue was deleted previously when there was still a > consumer attached?" > > I'm not sure if it's what you asked but I did try to delete the queue from > the consumer itself, without stopping the subscription. Did that succeed? I.e. was that delete a different attempt from the one that failed with not-found? Deleting a queue for which there is a subscription open will result in the queue being removed from the registry but still existing as an object within the broker. A subsequent attempt to delete it would fail with a not-found. > > -----Message d'origine----- > De : Gordon Sim [mailto:[email protected]] > Envoyé : mardi 28 juillet 2009 12:04 > À : [email protected] > Objet : Re: Queue.Delete with Qpid 0.5 +> Queue Not Found > > Julien Lavigne du Cadet wrote: >> Hi, I'm trying to delete a queue with Qpid 0.5, please see the log below. >> As far as I understand, this line tends to show that the queue exists : >> 2009-jul-28 10:27:59 debug No messages to dispatch on queue >> 'management.Spy.40006ee0-17cf-4c6d-bb2c-6533e19d8c99' >> >> However, just a few lines after, I get this when sending a Queue.Delete >> message : >> 2009-jul-28 10:28:06 debug Exception constructed: Queue not found: >> management.Spy.40006ee0-17cf-4c6d-bb2c-6533e19d8c99 >> (.\qpid\broker\SessionAdapter.cpp:742) > > Is it possible that the queue was deleted previously when there was > still a consumer attached? > > The exception indicates that the queue is not in the queue registry. > However the earlier line indicates that it still exists and has a > consumer attached to it. > > If a queue is deleted from 'under' a consumer, then at present the queue > object will continue to exist until that consumer is closed. However it > will not be visible to any of the AMQP commands (message-subscribe, > queue-delete, queue-query, exchange-bind etc). (A consequence of this is > that declaring a new queue of the same name will succeed, and the > management tools will show two queue with the same name). > >> Any suggestions? >> >> Julien >> >> >> >> 2009-jul-28 10:27:59 debug No messages to dispatch on queue >> 'management.reply.150786417-13afb-14b5c-18f8e-1f1787699dc0e' >> 2009-jul-28 10:27:59 debug No messages to dispatch on queue >> 'management.Spy.40006ee0-17cf-4c6d-bb2c-6533e19d8c99' >> 2009-jul-28 10:27:59 debug No messages to dispatch on queue >> 'management.150786417-13afb-14b5c-18f8e-1f1787699dc0e' >> 2009-jul-28 10:27:59 trace RECV [127.0.0.1:4573]: Frame[BEbe; channel=1; >> {MessageAcceptBody: transfers={ [151,151] }; }] >> 2009-jul-28 10:27:59 trace guest.1f9817ea6-13cc1-14b1c-1b19a-13160ad10a1d9: >> recv cmd 209: {MessageAcceptBody: transfers={ [151,151] }; } >> 2009-jul-28 10:27:59 debug DeliveryRecord::setEnded() id=151 >> 2009-jul-28 10:27:59 debug Accepted 151 >> 2009-jul-28 10:27:59 debug guest.1f9817ea6-13cc1-14b1c-1b19a-13160ad10a1d9: >> receiver marked completed: 209 incomplete: { } unknown-completed: { [1,209] } >> 2009-jul-28 10:28:06 trace RECV [127.0.0.1:4573]: Frame[BEbe; channel=1; >> {QueueDeleteBody: >> queue=management.Spy.40006ee0-17cf-4c6d-bb2c-6533e19d8c99;}] >> 2009-jul-28 10:28:06 trace guest.1f9817ea6-13cc1-14b1c-1b19a-13160ad10a1d9: >> recv cmd 210: {QueueDeleteBody: >> queue=management.Spy.40006ee0-17cf-4c6d-bb2c-6533e19d8c99; } >> 2009-jul-28 10:28:06 debug Exception constructed: Queue not found: >> management.Spy.40006ee0-17cf-4c6d-bb2c-6533e19d8c99 >> (.\qpid\broker\SessionAdapter.cpp:742) >> 2009-jul-28 10:28:06 error Execution exception: not-found: Queue not found: >> management.Spy.40006ee0-17cf-4c6d-bb2c-6533e19d8c99 >> (.\qpid\broker\SessionAdapter.cpp:742) >> 2009-jul-28 10:28:06 trace SENT [127.0.0.1:4573]: Frame[BEbe; channel=1; >> {ExecutionExceptionBody: error-code=404; command-id=210; class-code=8; >> command-code=2; field-index=0; description=not-found: Queue not found: >> management.Spy.40006ee0-17cf-4c6d-bb2c-6533e19d8c99 >> (.\qpid\broker\SessionAdapter.cpp:742); error-info={}; }] >> 2009-jul-28 10:28:06 trace SENT [127.0.0.1:4573]: Frame[BEbe; channel=1; >> {SessionDetachBody: name=1f9817ea6-13cc1-14b1c-1b19a-13160ad10a1d9; }] >> 2009-jul-28 10:28:26 debug Message 00657DA0 enqueued on >> management.150786417-13afb-14b5c-18f8e-1f1787699dc0e[006461D8] >> 2009-jul-28 10:28:26 debug Message 00655D30 enqueued on >> management.150786417-13afb-14b5c-18f8e-1f1787699dc0e[006461D8] >> 2009-jul-28 10:28:26 debug Message 006997C8 enqueued on >> management.150786417-13afb-14b5c-18f8e-1f1787699dc0e[006461D8] >> 2009-jul-28 10:28:26 debug Message 0069A1B0 enqueued on >> management.150786417-13afb-14b5c-18f8e-1f1787699dc0e[006461D8] >> 2009-jul-28 10:28:26 debug Message 0064DD40 enqueued on >> management.150786417-13afb-14b5c-18f8e-1f1787699dc0e[006461D8] >> 2009-jul-28 10:28:26 debug Message 00655398 enqueued on >> management.150786417-13afb-14b5c-18f8e-1f1787699dc0e[006461D8] >> 2009-jul-28 10:28:31 debug DISCONNECTED [127.0.0.1:4573] >> 2009-jul-28 10:28:31 debug guest.1f9817ea6-13cc1-14b1c-1b19a-13160ad10a1d9: >> detached on broker. >> ______________________________________ >> Sent from my www.pageflakes.com startpage >> >> --------------------------------------------------------------------- >> Apache Qpid - AMQP Messaging Implementation >> Project: http://qpid.apache.org >> Use/Interact: mailto:[email protected] >> > > > --------------------------------------------------------------------- > Apache Qpid - AMQP Messaging Implementation > Project: http://qpid.apache.org > Use/Interact: mailto:[email protected] > > > P Please consider your environmental responsibility before printing this > email > > ********************************************************************************* > Ce message peut contenir des informations confidentielles. > Les idees et opinions presentees dans ce message > sont celles de son auteur, et ne representent pas necessairement > celles du groupe ABC arbitrage. > Au cas ou il ne vous serait pas destine, > merci d'en aviser l'expediteur immediatement et de le supprimer. > > This message may contain confidential information. > Any views or opinions presented are solely those of its author > and do not necessarily represent those of ABC arbitrage. > If you are not the intended recipient, > please notify the sender immediately and delete it. > ********************************************************************************* > > > > --------------------------------------------------------------------- > Apache Qpid - AMQP Messaging Implementation > Project: http://qpid.apache.org > Use/Interact: mailto:[email protected] > --------------------------------------------------------------------- Apache Qpid - AMQP Messaging Implementation Project: http://qpid.apache.org Use/Interact: mailto:[email protected] P Please consider your environmental responsibility before printing this email ********************************************************************************* Ce message peut contenir des informations confidentielles. Les idees et opinions presentees dans ce message sont celles de son auteur, et ne representent pas necessairement celles du groupe ABC arbitrage. Au cas ou il ne vous serait pas destine, merci d'en aviser l'expediteur immediatement et de le supprimer. This message may contain confidential information. Any views or opinions presented are solely those of its author and do not necessarily represent those of ABC arbitrage. If you are not the intended recipient, please notify the sender immediately and delete it. ********************************************************************************* --------------------------------------------------------------------- Apache Qpid - AMQP Messaging Implementation Project: http://qpid.apache.org Use/Interact: mailto:[email protected]
