diff options
| author | Rajith Muditha Attapattu <rajith@apache.org> | 2009-02-25 23:24:45 +0000 |
|---|---|---|
| committer | Rajith Muditha Attapattu <rajith@apache.org> | 2009-02-25 23:24:45 +0000 |
| commit | 3d47fbb591b4ed055bdb2a5a7c26767c2ec3413a (patch) | |
| tree | d67f1ffe22c943ae54ff3c1443c0cd31fabce205 /qpid/java/client | |
| parent | a7484073368b0334cd174074bc4576f031a5ebe1 (diff) | |
| download | qpid-python-3d47fbb591b4ed055bdb2a5a7c26767c2ec3413a.tar.gz | |
This is related to QPID-1106
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@747964 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/client')
| -rw-r--r-- | qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java | 10 |
1 files changed, 8 insertions, 2 deletions
diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java b/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java index 9db2007e1a..8bf6e7aef1 100644 --- a/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java +++ b/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java @@ -261,9 +261,7 @@ public class BasicMessageConsumer_0_10 extends BasicMessageConsumer<UnprocessedM _logger.debug("filterMessage - trying to acquire message"); } messageOk = acquireMessage(message); - _logger.debug("filterMessage - *************************************"); _logger.debug("filterMessage - message acquire status : " + messageOk); - _logger.debug("filterMessage - *************************************"); } return messageOk; } @@ -417,6 +415,14 @@ public class BasicMessageConsumer_0_10 extends BasicMessageConsumer<UnprocessedM { _session.acknowledgeMessage(msg.getDeliveryTag(), false); } + + if (_acknowledgeMode == org.apache.qpid.jms.Session.AUTO_ACKNOWLEDGE && + !_session.isInRecovery() && + _session.getAMQConnection().getSyncAck()) + { + ((AMQSession_0_10) getSession()).flushAcknowledgments(); + ((AMQSession_0_10) getSession()).getQpidSession().sync(); + } } Message receiveBrowse() throws JMSException |