python_SUITE: Add more debug messages

Author: dumbbell

deps/rabbitmq_stomp/test/python_SUITE_data/src/base.py

@@ -126,7 +126,10 @@ def tearDown(self):
         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)))

deps/rabbitmq_stomp/test/python_SUITE_data/src/x_queue_name.py

@@ -11,6 +11,7 @@
 import base
 import time
 import os
+import test_util
 
 class TestUserGeneratedQueueName(base.BaseTest):
 
@@ -29,6 +30,12 @@ def test_exchange_dest(self):
                 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 @@ def test_exchange_dest(self):
         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 @@ def test_topic_dest(self):
                 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 @@ def test_topic_dest(self):
         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)