Specify a new queue in manager

We don't want to pull messages from the default existing queues and treat
messages that other might expect, or miss some messages because they have
been treated by others listening to the default queue.

So we rather use our own queue where we expect messages to be routed from
the subscribed topic.

Change-Id: Ibeda4ca1deb4db6eaecf49998b96e6ceb1087e77
Signed-off-by: Julien Danjou <julien@danjou.info>
This commit is contained in:
Julien Danjou 2012-09-25 15:57:30 +02:00
parent 69d3b91a0c
commit 913c33c341
1 changed files with 1 additions and 0 deletions

View File

@ -67,6 +67,7 @@ class CollectorManager(manager.Manager):
for topic in self.handler.topics:
self.connection.declare_topic_consumer(
topic=topic,
queue_name="ceilometer.notifications",
callback=functools.partial(self.handler.notify, topic))
# Set ourselves up as a separate worker for the metering data,