summaryrefslogtreecommitdiff
path: root/java/client/src
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
commit6eae55dbaf366e34227b5840a59bbe5631cd6558 (patch)
tree316555f6c86aae0c8938ebdf26ad235e6489cada /java/client/src
parent099399dc74fca798229976b67235ed83a6bb8718 (diff)
downloadqpid-python-6eae55dbaf366e34227b5840a59bbe5631cd6558.tar.gz
Changed for creating a dtx session
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@591952 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/client/src')
-rw-r--r--java/client/src/main/java/org/apache/qpidity/nclient/Client.java5
1 files changed, 3 insertions, 2 deletions
diff --git a/java/client/src/main/java/org/apache/qpidity/nclient/Client.java b/java/client/src/main/java/org/apache/qpidity/nclient/Client.java
index 8468cf299a..a5483a9c52 100644
--- a/java/client/src/main/java/org/apache/qpidity/nclient/Client.java
+++ b/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)