diff options
| author | Mehdi Abaakouk <sileht@redhat.com> | 2016-12-16 11:12:21 +0100 |
|---|---|---|
| committer | Mehdi Abaakouk <sileht@redhat.com> | 2017-01-02 11:33:55 +0100 |
| commit | 301a7d945a69a72bfd46deee45e15a8bae2b76ea (patch) | |
| tree | 2e824ac54df8985808208faba308c01795ee70e5 | |
| parent | 8fefbc064d30ec4fa530eb385629b4f05942ef0b (diff) | |
| download | oslo-messaging-301a7d945a69a72bfd46deee45e15a8bae2b76ea.tar.gz | |
tests: make rabbit failover failure more helpful
Change-Id: Ic50b9996e8b58d5b174b9e188d70a384240499ea
| -rw-r--r-- | oslo_messaging/tests/functional/test_rabbitmq.py | 9 |
1 files changed, 6 insertions, 3 deletions
diff --git a/oslo_messaging/tests/functional/test_rabbitmq.py b/oslo_messaging/tests/functional/test_rabbitmq.py index fb81f21..ffeaf0a 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)) |