openstack/designate
Code Issues Proposed changes

Merge "bug# 1198849 - from blallau"

Browse Source
This commit is contained in:
Jenkins 2013-07-09 14:56:29 +00:00 committed by Gerrit Code Review
commit b142a2ed6d
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
designate/sink/service.py
View File

@ -87,11 +87,11 @@ class Service(service.Service):
queue_name = "designate.notifications.%s.%s.%s" % (
handler.get_canonical_name(), exchange, topic)
self.rpc_conn.declare_topic_consumer(
queue_name=queue_name,
topic=topic,
exchange_name=exchange,
callback=self._process_notification)
self.rpc_conn.join_consumer_pool(
self._process_notification,
queue_name,
topic,
exchange_name=exchange)
def _get_handler_event_types(self):
event_types = set()