summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/SessionAdapter.cpp
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2008-03-11 21:56:49 +0000
committerGordon Sim <gsim@apache.org>2008-03-11 21:56:49 +0000
commit2250ec787ae5fb84fbebfee35bd9925ebd1dd679 (patch)
treedb1768a5f613ca2a70187c52b96896ca1ccdcfdc /cpp/src/qpid/broker/SessionAdapter.cpp
parentae650ea316f73b40db94a02556fd2cb335a7c816 (diff)
downloadqpid-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.cpp20
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()) {