summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/DtxBuffer.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/qpid/broker/DtxBuffer.cpp')
-rw-r--r--cpp/src/qpid/broker/DtxBuffer.cpp18
1 files changed, 17 insertions, 1 deletions
diff --git a/cpp/src/qpid/broker/DtxBuffer.cpp b/cpp/src/qpid/broker/DtxBuffer.cpp
index bdc326593a..2ffe744293 100644
--- a/cpp/src/qpid/broker/DtxBuffer.cpp
+++ b/cpp/src/qpid/broker/DtxBuffer.cpp
@@ -23,7 +23,7 @@
using namespace qpid::broker;
using qpid::sys::Mutex;
-DtxBuffer::DtxBuffer() : ended(false) {}
+DtxBuffer::DtxBuffer(const std::string& _xid) : xid(_xid), ended(false), suspended(false) {}
DtxBuffer::~DtxBuffer() {}
@@ -38,3 +38,19 @@ bool DtxBuffer::isEnded()
Mutex::ScopedLock locker(lock);
return ended;
}
+
+void DtxBuffer::setSuspended(bool isSuspended)
+{
+ suspended = isSuspended;
+}
+
+bool DtxBuffer::isSuspended()
+{
+ return suspended;
+}
+
+const std::string& DtxBuffer::getXid()
+{
+ return xid;
+}
+