Set durable=False on TopicPublisher, so that it matches the flag on

TopicConsumer.  This ensures that either redeclaration of the control_exchange
will use the same flag, and avoid AMQPChannelException.
This commit is contained in:
Ewan Mellor
2010-07-25 17:28:39 +01:00
parent 0c57be0d93
commit 744f79b82f

View File

@@ -151,6 +151,7 @@ class TopicPublisher(Publisher):
def __init__(self, connection=None, topic="broadcast"):
self.routing_key = topic
self.exchange = FLAGS.control_exchange
self.durable = False
super(TopicPublisher, self).__init__(connection=connection)