You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ar...@apache.org on 2008/06/06 11:56:45 UTC
svn commit: r663874 -
/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
Author: arnaudsimon
Date: Fri Jun 6 02:56:45 2008
New Revision: 663874
URL: http://svn.apache.org/viewvc?rev=663874&view=rev
Log:
QPID-1062: use sync flag instead of sync command on tx commit
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
Modified: incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java?rev=663874&r1=663873&r2=663874&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java (original)
+++ incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java Fri Jun 6 02:56:45 2008
@@ -220,9 +220,10 @@
*/
public void sendCommit() throws AMQException, FailoverException
{
+ getQpidSession().setAutoSync(true);
getQpidSession().txCommit();
+ getQpidSession().setAutoSync(false);
// We need to sync so that we get notify of an error.
- getQpidSession().sync();
getCurrentException();
}