← Back to branch summary

~zulcss/ubuntu/precise/quantum/trunk

« back to all changes in this revision

Viewing changes to quantum/agent/rpc.py

  • Committer: Chuck Short
  • Date: 2012-11-26 19:51:11 UTC
  • mfrom: (26.1.1 raring-proposed)
  • Revision ID: zulcss@ubuntu.com-20121126195111-jnz2cr4xi6whemw2
* New upstream release for the Ubuntu Cloud Archive.
* debian/patches/*: Refreshed for opening of Grizzly.
* New upstream release.
* debian/rules: FTFBS if there is missing binaries.
* debian/quantum-server.install: Add quantum-debug.

Show diffs side-by-side

added added

removed removed

Lines of Context:
quantum/agent/rpc.py
13
13
# See the License for the specific language governing permissions and
14
14
# limitations under the License.
15
15
 
16
 
import logging
17
 
 
18
16
import eventlet
19
17
 
20
18
from quantum.common import topics
21
19
 
 
20
from quantum.openstack.common import log as logging
 
21
from quantum.openstack.common.notifier import api
 
22
from quantum.openstack.common.notifier import rpc_notifier
22
23
from quantum.openstack.common import rpc
23
24
from quantum.openstack.common.rpc import proxy
24
 
from quantum.openstack.common.notifier import api
25
 
from quantum.openstack.common.notifier import rabbit_notifier
26
25
 
27
26
 
28
27
LOG = logging.getLogger(__name__)
85
84
        # being buffered in the process.
86
85
        self.queue = eventlet.queue.Queue(1)
87
86
        self.connection = rpc.create_connection(new=True)
88
 
        topic = '%s.%s' % (rabbit_notifier.CONF.notification_topics[0],
 
87
        topic = '%s.%s' % (rpc_notifier.CONF.notification_topics[0],
89
88
                           api.CONF.default_notification_level.lower())
90
89
        self.connection.declare_topic_consumer(topic=topic,
91
90
                                               callback=self._add_to_queue)