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.h | |
| 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.h')
| -rw-r--r-- | cpp/src/qpid/broker/SessionAdapter.h | 14 |
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 |
