From 0f009cce6c2e82f212b17fc5e98ef463d38af4a2 Mon Sep 17 00:00:00 2001 From: Kiall Mac Innes Date: Tue, 2 Oct 2012 16:13:16 +0100 Subject: Fix missing import of `rpc.dispatcher` in `rpc.service` Change-Id: I7bdd5fbff1addef4a855aa72f3551930630299f5 --- openstack/common/rpc/service.py | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) (limited to 'openstack') diff --git a/openstack/common/rpc/service.py b/openstack/common/rpc/service.py index 0c0255c..e572956 100644 --- a/openstack/common/rpc/service.py +++ b/openstack/common/rpc/service.py @@ -20,6 +20,7 @@ from openstack.common.gettextutils import _ from openstack.common import log as logging from openstack.common import rpc +from openstack.common.rpc import dispatcher as rpc_dispatcher from openstack.common import service @@ -46,15 +47,15 @@ class Service(service.Service): LOG.debug(_("Creating Consumer connection for Service %s") % self.topic) - rpc_dispatcher = rpc.dispatcher.RpcDispatcher([self.manager]) + dispatcher = rpc_dispatcher.RpcDispatcher([self.manager]) # Share this same connection for these Consumers - self.conn.create_consumer(self.topic, rpc_dispatcher, fanout=False) + self.conn.create_consumer(self.topic, dispatcher, fanout=False) node_topic = '%s.%s' % (self.topic, self.host) - self.conn.create_consumer(node_topic, rpc_dispatcher, fanout=False) + self.conn.create_consumer(node_topic, dispatcher, fanout=False) - self.conn.create_consumer(self.topic, rpc_dispatcher, fanout=True) + self.conn.create_consumer(self.topic, dispatcher, fanout=True) # Consume from all consumers in a thread self.conn.consume_in_thread() -- cgit