]> review.fuel-infra Code Review - openstack-build/neutron-build.git/commitdiff
Do not duplicate message consumers
authorIlya Shakhat <ishakhat@mirantis.com>
Wed, 21 Jan 2015 12:56:19 +0000 (15:56 +0300)
committerIlya Shakhat <ishakhat@mirantis.com>
Fri, 23 Jan 2015 16:34:38 +0000 (19:34 +0300)
Oslo.messaging creates node topic (with node name as suffix)
and fanout topic automatically. There's no need to do this
in Neutron code.

Closes bug 1413156

Change-Id: Ic790cab648b213b55679038967fef12eb5cec606

neutron/common/rpc.py

index 5a345f5ae5b064461ca14e4bf1d19a9680f2d012..aeb4cb4d37be2e0b9e81f6490a42c0943f5a27ef 100644 (file)
@@ -158,13 +158,7 @@ class Service(service.Service):
 
         endpoints = [self.manager]
 
-        # Share this same connection for these Consumers
-        self.conn.create_consumer(self.topic, endpoints, fanout=False)
-
-        node_topic = '%s.%s' % (self.topic, self.host)
-        self.conn.create_consumer(node_topic, endpoints, fanout=False)
-
-        self.conn.create_consumer(self.topic, endpoints, fanout=True)
+        self.conn.create_consumer(self.topic, endpoints)
 
         # Hook to allow the manager to do other initializations after
         # the rpc connection is created.