diff --git a/oslo_messaging/_drivers/base.py b/oslo_messaging/_drivers/base.py
index 456ffeb25..073f8555d 100644
--- a/oslo_messaging/_drivers/base.py
+++ b/oslo_messaging/_drivers/base.py
@@ -14,6 +14,7 @@
 #    under the License.
 
 import abc
+import time
 
 from oslo_config import cfg
 from oslo_utils import timeutils
@@ -51,6 +52,7 @@ def batch_poll_helper(func):
                 else:
                     # timeout reached or listener stopped
                     break
+                time.sleep(0)
         return incomings
     return wrapper