summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/DtxHandlerImpl.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/qpid/broker/DtxHandlerImpl.cpp')
-rw-r--r--cpp/src/qpid/broker/DtxHandlerImpl.cpp4
1 files changed, 1 insertions, 3 deletions
diff --git a/cpp/src/qpid/broker/DtxHandlerImpl.cpp b/cpp/src/qpid/broker/DtxHandlerImpl.cpp
index d1f925e40c..72d3888e37 100644
--- a/cpp/src/qpid/broker/DtxHandlerImpl.cpp
+++ b/cpp/src/qpid/broker/DtxHandlerImpl.cpp
@@ -52,7 +52,6 @@ const int XA_OK(8);
void DtxHandlerImpl::select()
{
channel.selectDtx();
- dClient.selectOk();
}
void DtxHandlerImpl::end(u_int16_t /*ticket*/,
@@ -140,7 +139,7 @@ void DtxHandlerImpl::rollback(u_int16_t /*ticket*/,
void DtxHandlerImpl::recover(u_int16_t /*ticket*/,
bool /*startscan*/,
- u_int32_t /*endscan*/ )
+ bool /*endscan*/ )
{
//TODO: what do startscan and endscan actually mean?
@@ -193,7 +192,6 @@ void DtxHandlerImpl::setTimeout(u_int16_t /*ticket*/,
u_int32_t timeout)
{
broker.getDtxManager().setTimeout(xid, timeout);
- cClient.setTimeoutOk();
}
void DtxHandlerImpl::setResponseTo(framing::RequestId r)