diff options
| author | Sandy Walsh <sandy.walsh@rackspace.com> | 2011-03-03 16:28:04 -0400 |
|---|---|---|
| committer | Sandy Walsh <sandy.walsh@rackspace.com> | 2011-03-03 16:28:04 -0400 |
| commit | 2a6ce075e19af5700960e3fb22c213e43a2e24b4 (patch) | |
| tree | 98798b930a626493d7841e763100eb8505b49097 /nova/service.py | |
| parent | c297880fb7c007aa4f6b6a9f7b985ecc981d8fe2 (diff) | |
| download | nova-2a6ce075e19af5700960e3fb22c213e43a2e24b4.tar.gz nova-2a6ce075e19af5700960e3fb22c213e43a2e24b4.tar.xz nova-2a6ce075e19af5700960e3fb22c213e43a2e24b4.zip | |
start of fanout
Diffstat (limited to 'nova/service.py')
| -rw-r--r-- | nova/service.py | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/nova/service.py b/nova/service.py index f47358089..3ecf46525 100644 --- a/nova/service.py +++ b/nova/service.py @@ -84,6 +84,7 @@ class Service(object): conn1 = rpc.Connection.instance(new=True) conn2 = rpc.Connection.instance(new=True) + conn3 = rpc.Connection.instance(new=True) if self.report_interval: consumer_all = rpc.AdapterConsumer( connection=conn1, @@ -93,9 +94,14 @@ class Service(object): connection=conn2, topic='%s.%s' % (self.topic, self.host), proxy=self) + fanout = rpc.AdapterConsumer( + connection=conn2, + topic='%s_fanout' % self.topic, + proxy=self) self.timers.append(consumer_all.attach_to_eventlet()) self.timers.append(consumer_node.attach_to_eventlet()) + self.timers.append(fanout.attach_to_eventlet()) pulse = utils.LoopingCall(self.report_state) pulse.start(interval=self.report_interval, now=False) |