diff options
| author | Rafael H. Schloming <rhs@apache.org> | 2008-06-09 19:26:59 +0000 |
|---|---|---|
| committer | Rafael H. Schloming <rhs@apache.org> | 2008-06-09 19:26:59 +0000 |
| commit | 76e2ec81529864e243f6de7de8e897bc0700e649 (patch) | |
| tree | 4b6f48322d731f430ffe93c5694e5eb1783a9449 | |
| parent | c3c4531f21eeda3e4e110f1560ab7a27e4be526b (diff) | |
| download | qpid-python-76e2ec81529864e243f6de7de8e897bc0700e649.tar.gz | |
QPID-901: always reset the auto-sync mode even if the call fails
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@665841 13f79535-47bb-0310-9956-ffa450edef68
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java | 10 | ||||
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_10.java | 20 |
2 files changed, 21 insertions, 9 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 ab1db4933f..fdfdc61eb5 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 @@ -221,8 +221,14 @@ public class AMQSession_0_10 extends AMQSession public void sendCommit() throws AMQException, FailoverException { getQpidSession().setAutoSync(true); - getQpidSession().txCommit(); - getQpidSession().setAutoSync(false); + try + { + getQpidSession().txCommit(); + } + finally + { + getQpidSession().setAutoSync(false); + } // We need to sync so that we get notify of an error. getCurrentException(); } diff --git a/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_10.java b/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_10.java index 0702a52783..5eb066ec36 100644 --- a/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_10.java +++ b/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_10.java @@ -212,17 +212,23 @@ public class BasicMessageProducer_0_10 extends BasicMessageProducer boolean sync = (deliveryMode == DeliveryMode.PERSISTENT && getSession().getAMQConnection().getSyncPersistence()); - if(sync) + if (sync) { ssn.setAutoSync(true); } - ssn.messageTransfer(destination.getExchangeName().toString(), - message.get010Message(), - ssn.TRANSFER_CONFIRM_MODE_NOT_REQUIRED, - ssn.TRANSFER_ACQUIRE_MODE_PRE_ACQUIRE); - if (sync) + try + { + ssn.messageTransfer(destination.getExchangeName().toString(), + message.get010Message(), + ssn.TRANSFER_CONFIRM_MODE_NOT_REQUIRED, + ssn.TRANSFER_ACQUIRE_MODE_PRE_ACQUIRE); + } + finally { - ssn.setAutoSync(false); + if (sync) + { + ssn.setAutoSync(false); + } } } catch (IOException e) |