root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions 5 Packages Projects Releases Wiki Activity

python_SUITE: Add more debug messages

This commit is contained in:
Jean-Sébastien Pédron 2025-08-07 12:06:29 +02:00
parent 5bfb7bc26f
commit 0a5024b47e
No known key found for this signature in database
GPG Key ID: 39E99761A5FD94CC
2 changed files with 19 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
deps/rabbitmq_stomp/test/python_SUITE_data/src/base.py vendored
View File

@ -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)))

17
deps/rabbitmq_stomp/test/python_SUITE_data/src/x_queue_name.py vendored
View File

@ -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)