git.diff

diff --git a/kombu/transport/qpid.py b/kombu/transport/qpid.py
index 017d0c1a..7a9cca95 100644
--- a/kombu/transport/qpid.py
+++ b/kombu/transport/qpid.py
@@ -1691,17 +1691,27 @@ class Transport(base.Transport):
         start_time = monotonic()
         elapsed_time = -1
         while elapsed_time < timeout:
-            try:
-                receiver = self.session.next_receiver(timeout=timeout)
-                message = receiver.fetch()
-                queue = receiver.source
-            except QpidEmpty:
+            receivers = self.session.receivers[self.last_receiver:] + self.session.receivers[0:self.last_receiver]
+            for receiver in receivers:
+                try:
+                    message = receiver.fetch(timeout)
+                except QpidEmpty:
+                    continue
+                else:
+                    break
+            if message is None:
                 raise socket.timeout()
-            else:
-                connection._callbacks[queue](message)
+
+            self.last_receiver += 1
+            if self.last_receiver >= len(self.session.receivers):
+                self.last_receiver = 0
+
+            queue = receiver.source
+            connection._callbacks[queue](message)
             elapsed_time = monotonic() - start_time
         raise socket.timeout()
 
+
     def create_channel(self, connection):
         """Create and return a :class:`~kombu.transport.qpid.Channel`.