openstack/oslo.messaging
Code Issues Proposed changes

Merge "notif: Check the driver features in dispatcher"

Browse Source
This commit is contained in:
Jenkins 2015-12-11 04:17:21 +00:00 committed by Gerrit Code Review
commit 0a0e6d0d50
2 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
oslo_messaging/notify/dispatcher.py
View File

@ -56,6 +56,7 @@ class _NotificationDispatcherBase(dispatcher.DispatcherBase):
priorities)) priorities))
def _listen(self, transport): def _listen(self, transport):
transport._require_driver_features(requeue=self.allow_requeue)
return transport._listen_for_notifications(self._targets_priorities, return transport._listen_for_notifications(self._targets_priorities,
pool=self.pool) pool=self.pool)

2
oslo_messaging/notify/listener.py
View File

@ -137,7 +137,6 @@ def get_notification_listener(transport, targets, endpoints,
:type pool: str :type pool: str
:raises: NotImplementedError :raises: NotImplementedError
""" """
transport._require_driver_features(requeue=allow_requeue)
dispatcher = notify_dispatcher.NotificationDispatcher(targets, endpoints, dispatcher = notify_dispatcher.NotificationDispatcher(targets, endpoints,
serializer, serializer,
allow_requeue, pool) allow_requeue, pool)
@ -180,7 +179,6 @@ def get_batch_notification_listener(transport, targets, endpoints,
:type batch_timeout: int :type batch_timeout: int
:raises: NotImplementedError :raises: NotImplementedError
""" """
transport._require_driver_features(requeue=allow_requeue)
dispatcher = notify_dispatcher.BatchNotificationDispatcher( dispatcher = notify_dispatcher.BatchNotificationDispatcher(
targets, endpoints, serializer, allow_requeue, pool, targets, endpoints, serializer, allow_requeue, pool,
batch_size, batch_timeout) batch_size, batch_timeout)