diff options
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java b/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java index e43072422c..ab1db4933f 100644 --- a/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java +++ b/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java @@ -220,9 +220,10 @@ public class AMQSession_0_10 extends AMQSession */ 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(); } |