summaryrefslogtreecommitdiff
path: root/qpid/java/client
diff options
context:
space:
mode:
authorArnaud Simon <arnaudsimon@apache.org>2007-11-05 10:47:26 +0000
committerArnaud Simon <arnaudsimon@apache.org>2007-11-05 10:47:26 +0000
commit077f50ac654edd3c596935c37f2d232aea8b929f (patch)
tree183f1b95f47aeaa81d1a21d92d8dab672b94985e /qpid/java/client
parent96baebc696cc5504e629dfcb5874b48c7dccb51c (diff)
downloadqpid-python-077f50ac654edd3c596935c37f2d232aea8b929f.tar.gz
Changed for creating a dtx session
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@591952 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/client')
-rw-r--r--qpid/java/client/src/main/java/org/apache/qpidity/nclient/Client.java5
1 files changed, 3 insertions, 2 deletions
diff --git a/qpid/java/client/src/main/java/org/apache/qpidity/nclient/Client.java b/qpid/java/client/src/main/java/org/apache/qpidity/nclient/Client.java
index 8468cf299a..a5483a9c52 100644
--- a/qpid/java/client/src/main/java/org/apache/qpidity/nclient/Client.java
+++ b/qpid/java/client/src/main/java/org/apache/qpidity/nclient/Client.java
@@ -124,8 +124,9 @@ public class Client implements org.apache.qpidity.nclient.Connection
public DtxSession createDTXSession(int expiryInSeconds)
{
- // TODO Auto-generated method stub
- return null;
+ ClientSession clientSession = (ClientSession) createSession(expiryInSeconds);
+ clientSession.dtxDemarcationSelect();
+ return (DtxSession) clientSession;
}
public void setClosedListener(ClosedListener closedListner)