1 files changed, 3 insertions, 2 deletions
diff --git a/cpp/src/qpid/broker/BrokerAdapter.cpp b/cpp/src/qpid/broker/BrokerAdapter.cpp
index 240973b060..36232339e5 100644
--- a/cpp/src/qpid/broker/BrokerAdapter.cpp
+++ b/cpp/src/qpid/broker/BrokerAdapter.cpp
@@ -42,7 +42,8 @@ BrokerAdapter::BrokerAdapter(Channel& ch, Connection& c, Broker& b) :
     exchangeHandler(*this),
     messageHandler(*this),
     queueHandler(*this),
-    txHandler(*this)    
+    txHandler(*this),
+    dtxHandler(*this)
 {}
 
 
@@ -336,7 +337,7 @@ void BrokerAdapter::BasicHandlerImpl::recover(const MethodContext&, bool requeue
 } 
 
 void BrokerAdapter::TxHandlerImpl::select(const MethodContext& context){
-    channel.begin();
+    channel.startTx();
     client.selectOk(context.getRequestId());
 }