From dee3a10e026896da06ff178335c0b3f86a7e6604 Mon Sep 17 00:00:00 2001 From: Alan Conway Date: Fri, 22 Aug 2014 14:13:09 +0000 Subject: NO-JIRA: Clean up test_store.cpp async functionality. Clean up test_store.cpp to allow control over async completion of messsages. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1619814 13f79535-47bb-0310-9956-ffa450edef68 --- qpid/cpp/src/tests/ha_tests.py | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) (limited to 'qpid/cpp/src/tests/ha_tests.py') diff --git a/qpid/cpp/src/tests/ha_tests.py b/qpid/cpp/src/tests/ha_tests.py index 58b3ff2802..e1864725d2 100755 --- a/qpid/cpp/src/tests/ha_tests.py +++ b/qpid/cpp/src/tests/ha_tests.py @@ -1514,16 +1514,15 @@ class TransactionTests(HaBrokerTest): self.assertRaises(Exception, commit_sync) def test_tx_backup_fail(self): - cluster = HaCluster( - self, 2, test_store=True, s_args=[[],["--test-store-throw=bang"]]) + cluster = HaCluster(self, 2, test_store=True, s_args=[[],["--test-store-name=bang"]]) c = cluster[0].connect(protocol=self.tx_protocol) tx = c.session(transactional=True) s = tx.sender("q;{create:always,node:{durable:true}}") - for m in ["foo","bang","bar"]: s.send(qm.Message(m, durable=True)) + for m in ["foo","TEST_STORE_DO bang: throw","bar"]: s.send(qm.Message(m, durable=True)) self.assert_commit_raises(tx) for b in cluster: b.assert_browse_backup("q", []) - self.assertEqual(open_read(cluster[0].store_log), "\n\n\n\n\n") - self.assertEqual(open_read(cluster[1].store_log), "\n\n\n\n") + self.assertEqual(open_read(cluster[0].store_log), "\n\n\n\n\n") + self.assertEqual(open_read(cluster[1].store_log), "\n\n\n\n") def test_tx_join_leave(self): """Test cluster members joining/leaving cluster. -- cgit v1.2.1