← Back to branch summary

~annegentle/nova/extdoc

« back to all changes in this revision

Viewing changes to nova/service.py

  • Committer: Chris Behrens
  • Date: 2011-08-29 21:36:12 UTC
  • mto: This revision was merged to the branch mainline in revision 1513.
  • Revision ID: cbehrens@codestud.com-20110829213612-gurxvyu9tqlpxqp2
ditched rpc.create_consumer(conn) interface... instead you now do conn.create_consumer(..

Show diffs side-by-side

added added

removed removed

Lines of Context:
nova/service.py
153
153
                      self.topic)
154
154
 
155
155
        # Share this same connection for these Consumers
156
 
        rpc.create_consumer(self.conn, self.topic, self,
157
 
                                           fanout=False)
 
156
        self.conn.create_consumer(self.topic, self, fanout=False)
158
157
 
159
158
        node_topic = '%s.%s' % (self.topic, self.host)
160
 
        rpc.create_consumer(self.conn, node_topic, self,
161
 
                                            fanout=False)
 
159
        self.conn.create_consumer(node_topic, self, fanout=False)
162
160
 
163
 
        rpc.create_consumer(self.conn, self.topic, self, fanout=True)
 
161
        self.conn.create_consumer(self.topic, self, fanout=True)
164
162
 
165
163
        # Consume from all consumers in a thread
166
164
        self.conn.consume_in_thread()