Author: arnaudsimon
Date: Mon Nov 5 02:47:26 2007
New Revision: 591952
URL: http://svn.apache.org/viewvc?rev=591952&view=rev
Log:
Changed for creating a dtx session
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/nclient/Client.java
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/nclient/Client.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/nclient/Client.java?rev=591952&r1=591951&r2=591952&view=diff
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/nclient/Client.java
(original)
+++
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/nclient/Client.java
Mon Nov 5 02:47:26 2007
@@ -124,8 +124,9 @@
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)
