diff --git a/oslo_messaging/notify/dispatcher.py b/oslo_messaging/notify/dispatcher.py
index afd34a270..72287678d 100644
--- a/oslo_messaging/notify/dispatcher.py
+++ b/oslo_messaging/notify/dispatcher.py
@@ -56,6 +56,7 @@ class _NotificationDispatcherBase(dispatcher.DispatcherBase):
                                                          priorities))
 
     def _listen(self, transport):
+        transport._require_driver_features(requeue=self.allow_requeue)
         return transport._listen_for_notifications(self._targets_priorities,
                                                    pool=self.pool)
 
diff --git a/oslo_messaging/notify/listener.py b/oslo_messaging/notify/listener.py
index 275da20c0..8855d5875 100644
--- a/oslo_messaging/notify/listener.py
+++ b/oslo_messaging/notify/listener.py
@@ -137,7 +137,6 @@ def get_notification_listener(transport, targets, endpoints,
     :type pool: str
     :raises: NotImplementedError
     """
-    transport._require_driver_features(requeue=allow_requeue)
     dispatcher = notify_dispatcher.NotificationDispatcher(targets, endpoints,
                                                           serializer,
                                                           allow_requeue, pool)
@@ -180,7 +179,6 @@ def get_batch_notification_listener(transport, targets, endpoints,
     :type batch_timeout: int
     :raises: NotImplementedError
     """
-    transport._require_driver_features(requeue=allow_requeue)
     dispatcher = notify_dispatcher.BatchNotificationDispatcher(
         targets, endpoints, serializer, allow_requeue, pool,
         batch_size, batch_timeout)