From 0a5024b47e9e72b186cb1f11e3a1ba4eea64a7c3 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Jean-S=C3=A9bastien=20P=C3=A9dron?= Date: Thu, 7 Aug 2025 12:06:29 +0200 Subject: [PATCH] python_SUITE: Add more debug messages --- .../test/python_SUITE_data/src/base.py | 5 ++++- .../test/python_SUITE_data/src/x_queue_name.py | 17 +++++++++++++++-- 2 files changed, 19 insertions(+), 3 deletions(-) diff --git a/deps/rabbitmq_stomp/test/python_SUITE_data/src/base.py b/deps/rabbitmq_stomp/test/python_SUITE_data/src/base.py index af643737c2..a08e5f03f5 100644 --- a/deps/rabbitmq_stomp/test/python_SUITE_data/src/base.py +++ b/deps/rabbitmq_stomp/test/python_SUITE_data/src/base.py @@ -126,7 +126,10 @@ class BaseTest(unittest.TestCase): if self.conn.is_connected(): try: self.conn.disconnect() - except: + except Exception as inst: + print(type(inst)) + print(inst.args) + print(inst) pass elapsed = time.time() - self._started_at print('{} ({}s)'.format(self.id(), round(elapsed, 2))) diff --git a/deps/rabbitmq_stomp/test/python_SUITE_data/src/x_queue_name.py b/deps/rabbitmq_stomp/test/python_SUITE_data/src/x_queue_name.py index 664228eb6f..a5e783d52d 100644 --- a/deps/rabbitmq_stomp/test/python_SUITE_data/src/x_queue_name.py +++ b/deps/rabbitmq_stomp/test/python_SUITE_data/src/x_queue_name.py @@ -11,6 +11,7 @@ import pika import base import time import os +import test_util class TestUserGeneratedQueueName(base.BaseTest): @@ -29,6 +30,12 @@ class TestUserGeneratedQueueName(base.BaseTest): pika.ConnectionParameters( host='127.0.0.1', port=int(os.environ["AMQP_PORT"]))) channel = connection.channel() + test_util.rabbitmqctl(['list_queues']) + test_util.rabbitmqctl(['list_connections', 'peer_host', 'peer_port', + 'protocol']) + test_util.rabbitmqctl(['list_stomp_connections', 'peer_host', + 'peer_port', 'protocol']) + # publish a message to the named queue channel.basic_publish( exchange='', @@ -39,7 +46,7 @@ class TestUserGeneratedQueueName(base.BaseTest): self.assertTrue(self.listener.wait(30), "initial message not received") self.assertEqual(1, len(self.listener.messages)) - self.conn.disconnect() + # self.conn.disconnect() connection.close() while not connection.is_closed: time.sleep(1) @@ -59,6 +66,12 @@ class TestUserGeneratedQueueName(base.BaseTest): pika.ConnectionParameters( host='127.0.0.1', port=int(os.environ["AMQP_PORT"]))) channel = connection.channel() + test_util.rabbitmqctl(['list_queues']) + test_util.rabbitmqctl(['list_connections', 'peer_host', 'peer_port', + 'protocol']) + test_util.rabbitmqctl(['list_stomp_connections', 'peer_host', + 'peer_port', 'protocol']) + # publish a message to the named queue channel.basic_publish( exchange='', @@ -69,7 +82,7 @@ class TestUserGeneratedQueueName(base.BaseTest): self.assertTrue(self.listener.wait(30), "initial message not received") self.assertEqual(1, len(self.listener.messages)) - self.conn.disconnect() + # self.conn.disconnect() connection.close() while not connection.is_closed: time.sleep(1)