diff options
| author | Martin Ritchie <ritchiem@apache.org> | 2006-12-20 17:04:33 +0000 |
|---|---|---|
| committer | Martin Ritchie <ritchiem@apache.org> | 2006-12-20 17:04:33 +0000 |
| commit | b4f1424fb7a2013448c87897f3be4baf8aff2027 (patch) | |
| tree | 8af4dff6adee9e9f1d580ad357480ce33d18d8c8 /java | |
| parent | 60f2d379eff857a6883eb848f9178da9434b5fa3 (diff) | |
| download | qpid-python-b4f1424fb7a2013448c87897f3be4baf8aff2027.tar.gz | |
QPID-225
Applied Patch for queue browsing with client acknowledgement
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@489140 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java')
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java | 15 |
1 files changed, 14 insertions, 1 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java b/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java index 673321cd9d..cefaca8d52 100644 --- a/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java +++ b/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java @@ -554,6 +554,12 @@ public class BasicMessageConsumer extends Closeable implements MessageConsumer msg.setJMSDestination(_destination); switch (_acknowledgeMode) { + case Session.CLIENT_ACKNOWLEDGE: + if (isNoConsume()) + { + _session.acknowledgeMessage(msg.getDeliveryTag(), false); + } + break; case Session.DUPS_OK_ACKNOWLEDGE: if (++_outstanding >= _prefetchHigh) { @@ -580,7 +586,14 @@ public class BasicMessageConsumer extends Closeable implements MessageConsumer } break; case Session.SESSION_TRANSACTED: - _lastDeliveryTag = msg.getDeliveryTag(); + if (isNoConsume()) + { + _session.acknowledgeMessage(msg.getDeliveryTag(), false); + } + else + { + _lastDeliveryTag = msg.getDeliveryTag(); + } break; } } |