[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