[rhmessaging-commits] rhmessaging commits: r1267 - store/trunk/cpp/tests.

rhmessaging-commits at lists.jboss.org rhmessaging-commits at lists.jboss.org
Thu Nov 8 09:06:24 EST 2007


Author: gordonsim
Date: 2007-11-08 09:06:24 -0500 (Thu, 08 Nov 2007)
New Revision: 1267

Modified:
   store/trunk/cpp/tests/persistence.py
Log:
Add check for restoration of bindings to standard exchange



Modified: store/trunk/cpp/tests/persistence.py
===================================================================
--- store/trunk/cpp/tests/persistence.py	2007-11-08 04:26:36 UTC (rev 1266)
+++ store/trunk/cpp/tests/persistence.py	2007-11-08 14:06:24 UTC (rev 1267)
@@ -55,6 +55,16 @@
         channel.queue_declare(queue="queue-a", durable=True, passive=True)
         channel.queue_declare(queue="queue-b", durable=True, passive=True)
 
+        #check they are still bound to amq.direct correctly
+        responses = []
+        responses.append(channel.binding_query(queue="queue-a", exchange="amq.direct", routing_key="a"))
+        responses.append(channel.binding_query(queue="queue-b", exchange="amq.direct", routing_key="b"))
+        for r in responses:
+            self.assertEqual(False, r.exchange_not_found)
+            self.assertEqual(False, r.queue_not_found)
+            self.assertEqual(False, r.key_not_matched)        
+
+
         #check expected messages are there        
         self.assertMessageOnQueue("queue-a", "Msg0001", "A_Message1")
         self.assertMessageOnQueue("queue-b", "Msg0002", "B_Message1")




More information about the rhmessaging-commits mailing list