From 2250ec787ae5fb84fbebfee35bd9925ebd1dd679 Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Tue, 11 Mar 2008 21:56:49 +0000 Subject: Enabled tx methods on final 0-10 path and converted tests accordingly Added read/write- uuid to codec010 git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@636121 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/broker/SessionAdapter.cpp | 20 +++++++++++++++++++- 1 file changed, 19 insertions(+), 1 deletion(-) (limited to 'cpp/src/qpid/broker/SessionAdapter.cpp') diff --git a/cpp/src/qpid/broker/SessionAdapter.cpp b/cpp/src/qpid/broker/SessionAdapter.cpp index 990727dda5..64bb7cdae3 100644 --- a/cpp/src/qpid/broker/SessionAdapter.cpp +++ b/cpp/src/qpid/broker/SessionAdapter.cpp @@ -38,7 +38,8 @@ SessionAdapter::SessionAdapter(SemanticState& s) : exchangeImpl(s), queueImpl(s), messageImpl(s), - executionImpl(s) + executionImpl(s), + txImpl(s) {} @@ -405,6 +406,23 @@ void SessionAdapter::ExecutionHandlerImpl::exception(uint16_t /*errorCode*/, } + +void SessionAdapter::TxHandlerImpl::select() +{ + state.startTx(); +} + +void SessionAdapter::TxHandlerImpl::commit() +{ + state.commit(&getBroker().getStore()); +} + +void SessionAdapter::TxHandlerImpl::rollback() +{ + state.rollback(); +} + + Queue::shared_ptr SessionAdapter::HandlerHelper::getQueue(const string& name) const { Queue::shared_ptr queue; if (name.empty()) { -- cgit v1.2.1