diff options
Diffstat (limited to 'cpp/src/qpid/asyncStore/AsyncStoreImpl.cpp')
-rw-r--r-- | cpp/src/qpid/asyncStore/AsyncStoreImpl.cpp | 32 |
1 files changed, 26 insertions, 6 deletions
diff --git a/cpp/src/qpid/asyncStore/AsyncStoreImpl.cpp b/cpp/src/qpid/asyncStore/AsyncStoreImpl.cpp index a9fc13363a..9135fcc27e 100644 --- a/cpp/src/qpid/asyncStore/AsyncStoreImpl.cpp +++ b/cpp/src/qpid/asyncStore/AsyncStoreImpl.cpp @@ -24,6 +24,7 @@ #include "AsyncStoreImpl.h" #include "AsyncOperation.h" +#include "TxnHandleImpl.h" #include "qpid/broker/ConfigHandle.h" #include "qpid/broker/EnqueueHandle.h" @@ -62,6 +63,31 @@ void AsyncStoreImpl::initManagement(qpid::broker::Broker* /*broker*/) {} +qpid::broker::TxnHandle +AsyncStoreImpl::createTxnHandle() +{ + return qpid::broker::TxnHandle(new TxnHandleImpl); +} + +qpid::broker::TxnHandle +AsyncStoreImpl::createTxnHandle(qpid::broker::TxnBuffer* tb) +{ + return qpid::broker::TxnHandle(new TxnHandleImpl(tb)); +} + +qpid::broker::TxnHandle +AsyncStoreImpl::createTxnHandle(const std::string& xid) +{ + return qpid::broker::TxnHandle(new TxnHandleImpl(xid)); +} + +qpid::broker::TxnHandle +AsyncStoreImpl::createTxnHandle(const std::string& xid, + qpid::broker::TxnBuffer* tb) +{ + return qpid::broker::TxnHandle(new TxnHandleImpl(xid, tb)); +} + qpid::broker::ConfigHandle AsyncStoreImpl::createConfigHandle() { @@ -96,12 +122,6 @@ AsyncStoreImpl::createQueueHandle(const std::string& name, return qpid::broker::QueueHandle(new QueueHandleImpl(name, opts)); } -qpid::broker::TxnHandle -AsyncStoreImpl::createTxnHandle(const std::string& xid) -{ - return qpid::broker::TxnHandle(new TxnHandleImpl(xid)); -} - void AsyncStoreImpl::submitPrepare(qpid::broker::TxnHandle& txnHandle, boost::shared_ptr<qpid::broker::BrokerAsyncContext> brokerCtxt) |