From e6598e9f95d55b80f96dbcb1e12bc1fc38c66af1 Mon Sep 17 00:00:00 2001 From: Alan Conway Date: Thu, 1 Aug 2013 20:27:26 +0000 Subject: QPID-4327: HA TX transactions: basic replication. On primary a PrimaryTxObserver observes a transaction's TxBuffer and generates transaction events on a tx-replication-queue. On the backup a TxReplicator receives the events and constructs a TxBuffer equivalent to the one in the primary. Unfinished: - Primary does not wait for backups to prepare() before committing. - All connected backups are assumed to be in the transaction, there are race conditions around brokers joining/leavinv where this assumption is invalid. - Need more tests. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1509423 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/tests/TransactionObserverTest.cpp | 1 + 1 file changed, 1 insertion(+) (limited to 'cpp/src/tests/TransactionObserverTest.cpp') diff --git a/cpp/src/tests/TransactionObserverTest.cpp b/cpp/src/tests/TransactionObserverTest.cpp index c284417e25..f570837ccf 100644 --- a/cpp/src/tests/TransactionObserverTest.cpp +++ b/cpp/src/tests/TransactionObserverTest.cpp @@ -89,6 +89,7 @@ Session simpleTxTransaction(MessagingFixture& fix) { // Transaction with 1 enqueue and 1 dequeue. Session txSession = fix.connection.createTransactionalSession(); BOOST_CHECK_EQUAL("foo", txSession.createReceiver("q1").fetch().getContent()); + txSession.acknowledge(); txSession.createSender("q2;{create:always}").send(msg("bar")); return txSession; } -- cgit v1.2.1