From 913c33c341609925d2dc93825142d50bc5f6f8c6 Mon Sep 17 00:00:00 2001 From: Julien Danjou Date: Tue, 25 Sep 2012 15:57:30 +0200 Subject: [PATCH] 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 --- ceilometer/collector/manager.py | 1 + 1 file changed, 1 insertion(+) diff --git a/ceilometer/collector/manager.py b/ceilometer/collector/manager.py index 04d25c61..85b033cb 100644 --- a/ceilometer/collector/manager.py +++ b/ceilometer/collector/manager.py @@ -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,