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

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"""