x/python-ganttclient
Code Issues Proposed changes

fanout works

Browse Source
This commit is contained in:
Sandy Walsh
2011-02-20 22:33:39 -08:00
parent a06093b1f0
commit e860e7d550
1 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
nova/rpc.py
View File

@@ -215,8 +215,12 @@ class FanoutAdapterConsumer(AdapterConsumer):
def __init__(self, connection=None, topic="broadcast", proxy=None): def __init__(self, connection=None, topic="broadcast", proxy=None):
self.exchange = "%s_fanout" % topic self.exchange = "%s_fanout" % topic
self.routing_key = topic self.routing_key = topic
self.queue = "ignored" unique = uuid.uuid4().hex
self.queue = "%s_fanout_%s" % (topic, unique)
self.durable = False self.durable = False
LOG.info(_("Created '%(exchange)s' fanout exchange "
"with '%(key)s' routing key"),
dict(exchange=self.exchange, key=self.routing_key))
super(FanoutAdapterConsumer, self).__init__(connection=connection, super(FanoutAdapterConsumer, self).__init__(connection=connection,
topic=topic, proxy=proxy) topic=topic, proxy=proxy)
@@ -228,7 +232,6 @@ class TopicPublisher(Publisher):
def __init__(self, connection=None, topic="broadcast"): def __init__(self, connection=None, topic="broadcast"):
self.routing_key = topic self.routing_key = topic
self.exchange = FLAGS.control_exchange self.exchange = FLAGS.control_exchange
self.queue = "ignored"
self.durable = False self.durable = False
super(TopicPublisher, self).__init__(connection=connection) super(TopicPublisher, self).__init__(connection=connection)
@@ -239,7 +242,10 @@ class FanoutPublisher(Publisher):
def __init__(self, topic, connection=None): def __init__(self, topic, connection=None):
self.exchange = "%s_fanout" % topic self.exchange = "%s_fanout" % topic
self.queue = "%s_fanout" % topic
self.durable = False self.durable = False
LOG.info(_("Writing to '%(exchange)s' fanout exchange"),
dict(exchange=self.exchange))
super(FanoutPublisher, self).__init__(connection=connection) super(FanoutPublisher, self).__init__(connection=connection)