Bug #719

o dispatcher σκάει όταν πάει να διαλύσει τις ουρές AMQP

Added by Vangelis Koukis almost 11 years ago. Updated almost 11 years ago.

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

Revision 979482ce
Added by Giorgos Gousios almost 11 years ago

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

Revision e6209aa2
Added by Giorgos Gousios almost 11 years ago

Dispatcher support for draining queues

Refs: #719

History

#1 Updated by Giorgos Gousios almost 11 years ago

Fixed as of revision e6209aa2aa

#2 Updated by Giorgos Gousios almost 11 years ago

  • % Done changed from 0 to 100

#3 Updated by Vangelis Koukis almost 11 years ago

  • Status changed from Assigned to Closed

Αυτό φαίνεται να δουλεύει, έχουν προστεθεί έξτρα παράμετροι στη γραμμή εντολών για την καταστροφή ουρών, το ticket κλείνει.

Also available in: Atom PDF