diff --git a/oslo_messaging/_drivers/base.py b/oslo_messaging/_drivers/base.py index 2051e9a30..0c0008269 100644 --- a/oslo_messaging/_drivers/base.py +++ b/oslo_messaging/_drivers/base.py @@ -112,7 +112,7 @@ class BaseDriver(object): """Construct a Listener for the given target.""" @abc.abstractmethod - def listen_for_notifications(self, targets_and_priorities): + def listen_for_notifications(self, targets_and_priorities, pool): """Construct a notification Listener for the given list of tuple of (target, priority). """