diff options
author | Gordon Sim <gsim@apache.org> | 2008-03-11 21:56:49 +0000 |
---|---|---|
committer | Gordon Sim <gsim@apache.org> | 2008-03-11 21:56:49 +0000 |
commit | 2250ec787ae5fb84fbebfee35bd9925ebd1dd679 (patch) | |
tree | db1768a5f613ca2a70187c52b96896ca1ccdcfdc /cpp/src/qpid/broker/SessionAdapter.cpp | |
parent | ae650ea316f73b40db94a02556fd2cb335a7c816 (diff) | |
download | qpid-python-2250ec787ae5fb84fbebfee35bd9925ebd1dd679.tar.gz |
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
Diffstat (limited to 'cpp/src/qpid/broker/SessionAdapter.cpp')
-rw-r--r-- | cpp/src/qpid/broker/SessionAdapter.cpp | 20 |
1 files changed, 19 insertions, 1 deletions
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()) { |