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 | 68e2753ce44d34758252a8d0176ab64a24ff2d9d (patch) | |
| tree | 3c2b43bcab07f36da2c89a25ebc0c945e6a1619c /java/client/src | |
| parent | 94a2e74021b5796280b7e4464a02eb80824f9664 (diff) | |
| download | qpid-python-68e2753ce44d34758252a8d0176ab64a24ff2d9d.tar.gz | |
This is related to QPID-1106
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@747964 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/client/src')
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java | 10 |
1 files changed, 8 insertions, 2 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java b/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java index 9db2007e1a..8bf6e7aef1 100644 --- a/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java +++ b/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 |