[rabbitmq-discuss] Not receiving notifications about queue deletions from the server.

[Njal Karevoll]

Hi,

I don't seem to receive any notifications from the server when a queue I am 
consuming is deleted. Both the server and the client is stating they support 
consumer_cancel_notify. 

Here is a dump of all the frames received and sent by the client:

2011-09-24 14:15:25+0200 SENDING <ProtocolHeader(['frame_type=-1', 
'major=0', 'minor=9', 'revision=1'])>
2011-09-24 14:15:25+0200 RECEIVED: <Method(['frame_type=1', 
'channel_number=0', 
'method=<Connection.Start(["server_properties={\'information\': \'Licensed 
under the MPL.  See http://www.rabbitmq.com/\', \'product\': \'RabbitMQ\', 
\'copyright\': \'Copyright (C) 2007-2011 VMware, Inc.\', \'capabilities\': 
{\'exchange_exchange_bindings\': True, \'consumer_cancel_notify\': True, 
\'publisher_confirms\': True, \'basic.nack\': True}, \'platform\': 
\'Erlang/OTP\', \'version\': \'2.6.1\'}", \'version_minor=9\', 
\'mechanisms=PLAIN AMQPLAIN\', \'locales=en_US\', \'version_major=0\'])>'])>
2011-09-24 14:15:25+0200 SENDING <Method(['frame_type=1', 
'channel_number=0', 'method=<Connection.StartOk([\'locale=en_US\', 
\'mechanism=PLAIN\', "client_properties={\'client-properties\': 
{\'consumer_cancel_notify\': True, \'publisher_confirms\': True, 
\'basic.nack\': True}, \'platform\': \'Python 2.7.1\', \'product\': \'Pika 
Python Client Library\', \'version\': \'0.9.6-pre0\', \'information\': \'See 
http://pika.github.com\'}", \'response=\\x00guest\\x00guest\'])>'])>
2011-09-24 14:15:25+0200 RECEIVED: <Method(['frame_type=1', 
'channel_number=0', "method=<Connection.Tune(['frame_max=131072', 
'channel_max=0', 'heartbeat=0'])>"])>
2011-09-24 14:15:25+0200 SENDING <Method(['frame_type=1', 
'channel_number=0', "method=<Connection.TuneOk(['frame_max=131072', 
'channel_max=0', 'heartbeat=True'])>"])>
2011-09-24 14:15:25+0200 SENDING <Method(['frame_type=1', 
'channel_number=0', "method=<Connection.Open(['insist=True', 
'capabilities=', 'virtual_host=/'])>"])>
2011-09-24 14:15:25+0200 RECEIVED: <Method(['frame_type=1', 
'channel_number=0', "method=<Connection.OpenOk(['known_hosts='])>"])>
2011-09-24 14:15:25+0200 SENDING <Method(['frame_type=1', 
'channel_number=1', "method=<Channel.Open(['out_of_band='])>"])>
2011-09-24 14:15:25+0200 finished keeping connect working
2011-09-24 14:15:25+0200 RECEIVED: <Method(['frame_type=1', 
'channel_number=1', "method=<Channel.OpenOk(['channel_id='])>"])>
2011-09-24 14:15:25+0200 SENDING <Method(['frame_type=1', 
'channel_number=1', "method=<Basic.Qos(['prefetch_count=2', 
'prefetch_size=0', 'global_=False'])>"])>
2011-09-24 14:15:25+0200 RECEIVED: <Method(['frame_type=1', 
'channel_number=1', 'method=<Basic.QosOk([])>'])>
2011-09-24 14:15:25+0200 SENDING <Method(['frame_type=1', 
'channel_number=1', "method=<Basic.Consume(['exclusive=False', 
'nowait=False', 'no_local=False', 'consumer_tag=ctag1.0', 
'queue=operations', 'arguments={}', 'ticket=0', 'no_ack=False'])>"])>
2011-09-24 14:15:25+0200 RECEIVED: <Method(['frame_type=1', 
'channel_number=1', "method=<Basic.ConsumeOk(['consumer_tag=ctag1.0'])>"])>
2011-09-24 14:15:26+0200 RECEIVED: <Heartbeat(['frame_type=8', 
'channel_number=0'])>
2011-09-24 14:15:27+0200 SENDING <Heartbeat(['frame_type=8', 
'channel_number=0'])>
2011-09-24 14:15:27+0200 RECEIVED: <Heartbeat(['frame_type=8', 
'channel_number=0'])>
# << deleted the queue using rabbitmq-management here >>
2011-09-24 14:15:28+0200 SENDING <Heartbeat(['frame_type=8', 
'channel_number=0'])>
2011-09-24 14:15:28+0200 RECEIVED: <Heartbeat(['frame_type=8', 
'channel_number=0'])>
2011-09-24 14:15:29+0200 SENDING <Heartbeat(['frame_type=8', 
'channel_number=0'])>
2011-09-24 14:15:29+0200 RECEIVED: <Heartbeat(['frame_type=8', 
'channel_number=0'])>
2011-09-24 14:15:30+0200 SENDING <Heartbeat(['frame_type=8', 
'channel_number=0'])>
2011-09-24 14:15:30+0200 RECEIVED: <Heartbeat(['frame_type=8', 
'channel_number=0'])>
2011-09-24 14:15:31+0200 SENDING <Heartbeat(['frame_type=8', 
'channel_number=0'])>
2011-09-24 14:15:31+0200 RECEIVED: <Heartbeat(['frame_type=8', 
'channel_number=0'])>
2011-09-24 14:15:32+0200 SENDING <Heartbeat(['frame_type=8', 
'channel_number=0'])>
2011-09-24 14:15:32+0200 RECEIVED: <Heartbeat(['frame_type=8', 
'channel_number=0'])>
2011-09-24 14:15:33+0200 SENDING <Heartbeat(['frame_type=8', 
'channel_number=0'])>
2011-09-24 14:15:33+0200 RECEIVED: <Heartbeat(['frame_type=8', 
'channel_number=0'])>

rabbitmq-management says the following about the connection:

client-propertiesconsumer_cancel_notify:truepublisher_confirms:true
basic.nack:trueplatformPython 2.7.1productPika Python Client Libraryversion
0.9.6-pre0informationSee http://pika.github.com
Im using RabbitMQ 2.6.1 (on OSX), Erlang 5.8.4.
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20110924/07c15755/attachment.htm>