diff --git a/oslo_messaging/tests/functional/test_rabbitmq.py b/oslo_messaging/tests/functional/test_rabbitmq.py
index fb81f2191..ffeaf0a92 100644
--- a/oslo_messaging/tests/functional/test_rabbitmq.py
+++ b/oslo_messaging/tests/functional/test_rabbitmq.py
@@ -138,6 +138,9 @@ class RabbitMQFailoverTests(test_utils.BaseTestCase):
             self.client.client.transport._driver._reply_q_conn,
         ]
 
-        for cctxt in connection_contexts:
-            socket = cctxt.connection.channel.connection.sock
-            self.assertEqual(port, socket.getpeername()[1])
+        ports = [cctxt.connection.channel.connection.sock.getpeername()[1]
+                 for cctxt in connection_contexts]
+
+        self.assertEqual([port] * len(ports), ports,
+                         "expected: %s, rpc-server: %s, rpc-client: %s, "
+                         "rpc-replies: %s" % tuple([port] + ports))