summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/SessionAdapter.h
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.h
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.h')
-rw-r--r--cpp/src/qpid/broker/SessionAdapter.h14
1 files changed, 13 insertions, 1 deletions
diff --git a/cpp/src/qpid/broker/SessionAdapter.h b/cpp/src/qpid/broker/SessionAdapter.h
index e83d58bc2f..e4c3a8676f 100644
--- a/cpp/src/qpid/broker/SessionAdapter.h
+++ b/cpp/src/qpid/broker/SessionAdapter.h
@@ -56,7 +56,7 @@ class SessionAdapter : public HandlerImpl, public framing::AMQP_ServerOperations
Exchange010Handler* getExchange010Handler(){ return &exchangeImpl; }
Queue010Handler* getQueue010Handler(){ return &queueImpl; }
Execution010Handler* getExecution010Handler(){ return &executionImpl; }
-
+ Tx010Handler* getTx010Handler(){ return &txImpl; }
BasicHandler* getBasicHandler() { throw framing::NotImplementedException("Class not implemented"); }
ExchangeHandler* getExchangeHandler(){ throw framing::NotImplementedException("Class not implemented"); }
@@ -201,10 +201,22 @@ class SessionAdapter : public HandlerImpl, public framing::AMQP_ServerOperations
};
+ class TxHandlerImpl : public Tx010Handler, public HandlerHelper
+ {
+ public:
+ TxHandlerImpl(SemanticState& session) : HandlerHelper(session) {}
+
+ void select();
+ void commit();
+ void rollback();
+ };
+
+
ExchangeHandlerImpl exchangeImpl;
QueueHandlerImpl queueImpl;
MessageHandlerImpl messageImpl;
ExecutionHandlerImpl executionImpl;
+ TxHandlerImpl txImpl;
};
}} // namespace qpid::broker