← Back to branch summary

~ceilometer-drivers/ceilometer/trunk

« back to all changes in this revision

Viewing changes to ceilometer/openstack/common/rpc/service.py

  • Committer: Angus Salkeld
  • Date: 2012-11-03 00:31:11 UTC
  • Revision ID: git-v1:4c43441d9dafedbc1b73cf8abdec32b1ccb65a71
Update common (except policy)

Change-Id: I17a89a15ff3af5b9f31bf14b1bbe29b024cfc8c1

Show diffs side-by-side

added added

removed removed

Lines of Context:
ceilometer/openstack/common/rpc/service.py
20
20
from ceilometer.openstack.common.gettextutils import _
21
21
from ceilometer.openstack.common import log as logging
22
22
from ceilometer.openstack.common import rpc
 
23
from ceilometer.openstack.common.rpc import dispatcher as rpc_dispatcher
23
24
from ceilometer.openstack.common import service
24
25
 
25
26
 
46
47
        LOG.debug(_("Creating Consumer connection for Service %s") %
47
48
                  self.topic)
48
49
 
49
 
        rpc_dispatcher = rpc.dispatcher.RpcDispatcher([self.manager])
 
50
        dispatcher = rpc_dispatcher.RpcDispatcher([self.manager])
50
51
 
51
52
        # Share this same connection for these Consumers
52
 
        self.conn.create_consumer(self.topic, rpc_dispatcher, fanout=False)
 
53
        self.conn.create_consumer(self.topic, dispatcher, fanout=False)
53
54
 
54
55
        node_topic = '%s.%s' % (self.topic, self.host)
55
 
        self.conn.create_consumer(node_topic, rpc_dispatcher, fanout=False)
 
56
        self.conn.create_consumer(node_topic, dispatcher, fanout=False)
56
57
 
57
 
        self.conn.create_consumer(self.topic, rpc_dispatcher, fanout=True)
 
58
        self.conn.create_consumer(self.topic, dispatcher, fanout=True)
58
59
 
59
60
        # Consume from all consumers in a thread
60
61
        self.conn.consume_in_thread()