Bug #719
o dispatcher σκάει όταν πάει να διαλύσει τις ουρές AMQP
Status: | Closed | Start date: | 07/03/2011 | |
---|---|---|---|---|
Priority: | Medium | Due date: | ||
Assignee: | Giorgos Gousios | % Done: | 100% |
|
Category: | logic | Spent time: | - | |
Target version: | v0.5.1 |
Description
devel@store67:~/synnefo [master]$ ./logic/dispatcher.py -c 2011-07-03 16:58:16,452 - amqplib[17503] - DEBUG - Start from server, version: 8.0, properties: {u'information': 'Licensed under the MPL. See http://www.rabbitmq.com/', u'product': 'RabbitMQ', u'copyright': 'Copyright (C) 2007-2011 VMware, Inc.', u'capabilities': {}, u'platform': 'Erlang/OTP', u'version': '2.4.1'}, mechanisms: ['PLAIN', 'AMQPLAIN'], locales: ['en_US'] 2011-07-03 16:58:16,493 - amqplib[17503] - DEBUG - Open OK! known_hosts [] 2011-07-03 16:58:16,493 - amqplib[17503] - DEBUG - using channel_id: 1 2011-07-03 16:58:16,494 - amqplib[17503] - DEBUG - Channel open Queues to be deleted: ('events', 'credits', 'email', 'reconciliation', 'events-snf-op', 'events-snf-net', 'events-vkoukis-op', 'events- vkoukis-net', 'events-vkoukis-op', 'events-vkoukis-net') Exchnages to be deleted: ('ganeti', 'cron', 'api') Are you sure (N/y):y 2011-07-03 16:58:18,049 - amqplib[17503] - DEBUG - Closed channel #1 404 NOT_FOUND - no queue 'events-vkoukis-op' in vhost '/' Traceback (most recent call last): File "./logic/dispatcher.py", line 300, in <module> sys.exit(main()) File "./logic/dispatcher.py", line 241, in main cleanup_queues() File "./logic/dispatcher.py", line 218, in cleanup_queues chan.queue_delete(queue=queue) File "/usr/lib/pymodules/python2.6/amqplib/client_0_8/channel.py", line 1418, in queue_delete self._send_method((50, 40), args) File "/usr/lib/pymodules/python2.6/amqplib/client_0_8/abstract_channel.py", line 69, in _send_method self.connection.method_writer.write_method(self.channel_id, AttributeError: 'NoneType' object has no attribute 'method_writer'
Associated revisions
Introduce queue mgmt functions
Introduces the following three commands to the dispatcher, used to process queue declarations and stale messages
--purge-queues
--purge-exchanges
--drain-queue (not fully implemented yet)
Refs: #719
Dispatcher support for draining queues
Refs: #719
History
#1 Updated by Giorgos Gousios almost 13 years ago
Fixed as of revision e6209aa2aa
#2 Updated by Giorgos Gousios almost 13 years ago
- % Done changed from 0 to 100
#3 Updated by Vangelis Koukis almost 13 years ago
- Status changed from Assigned to Closed
Αυτό φαίνεται να δουλεύει, έχουν προστεθεί έξτρα παράμετροι στη γραμμή εντολών για την καταστροφή ουρών, το ticket κλείνει.