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

[rhmessaging-commits at lists.jboss.org]

Author: gordonsim
Date: 2010-06-02 15:33:45 -0400 (Wed, 02 Jun 2010)
New Revision: 4005

Modified:
   store/trunk/cpp/tests/python_tests/client_persistence.py
   store/trunk/cpp/tests/python_tests/store_test.py
Log:
Set reliability for link to prevent auto-delete being set on subscription queues (broker now cleans these up even for connections that are open when broker is shutdown)

Modified: store/trunk/cpp/tests/python_tests/client_persistence.py
===================================================================
--- store/trunk/cpp/tests/python_tests/client_persistence.py	2010-06-02 15:36:13 UTC (rev 4004)
+++ store/trunk/cpp/tests/python_tests/client_persistence.py	2010-06-02 19:33:45 UTC (rev 4005)
@@ -103,9 +103,9 @@
         broker = self.broker(store_args(), name="testFanout", expect=EXPECT_EXIT_OK)
         ssn = broker.connect().session()
         snd = ssn.sender("TestFanoutExchange; {create: always, node: {type: topic, x-declare: {type: fanout}}}")
-        ssn.receiver("TestFanoutExchange; {link: {name: \"q1\", durable: True}}")
-        ssn.receiver("TestFanoutExchange; {link: {name: \"q2\", durable: True}}")
-        ssn.receiver("TestFanoutExchange; {link: {name: \"q3\", durable: True}}")
+        ssn.receiver("TestFanoutExchange; {link: {name: \"q1\", durable: True, reliability:at-least-once}}")
+        ssn.receiver("TestFanoutExchange; {link: {name: \"q2\", durable: True, reliability:at-least-once}}")
+        ssn.receiver("TestFanoutExchange; {link: {name: \"q3\", durable: True, reliability:at-least-once}}")
         msg1 = Message("Msg1", durable=True, correlation_id="Msg0001")
         snd.send(msg1)
         msg2 = Message("Msg2", durable=True, correlation_id="Msg0002")

Modified: store/trunk/cpp/tests/python_tests/store_test.py
===================================================================
--- store/trunk/cpp/tests/python_tests/store_test.py	2010-06-02 15:36:13 UTC (rev 4004)
+++ store/trunk/cpp/tests/python_tests/store_test.py	2010-06-02 19:33:45 UTC (rev 4005)
@@ -301,9 +301,11 @@
         x_bindings_list = []
         for binding in binding_list:
             x_bindings_list.append("{exchange: %s, key: %s}" % binding)
+        if durable: reliability = 'at-least-once'
+        else: reliability = None
         return self.addr_fmt(node_name, create_policy=create_policy, delete_policy=delete_policy, mode=mode, link=True,
                              link_name=link_name, durable=durable, x_declare_list=x_declare_list,
-                             x_bindings_list=x_bindings_list)
+                             x_bindings_list=x_bindings_list, link_reliability=reliability)
     
     def check_message(self, broker, queue, exp_msg, transactional=False, empty=False, ack=True, browse=False):
         """Check that a message is on a queue by dequeuing it and comparing it to the expected message"""