diff options
| author | Aidan Skinner <aidan@apache.org> | 2008-10-17 16:10:46 +0000 |
|---|---|---|
| committer | Aidan Skinner <aidan@apache.org> | 2008-10-17 16:10:46 +0000 |
| commit | 63a400540399ad82bc264d98d12c59a29486bbaa (patch) | |
| tree | 3511fabd319bbdc3a2cc572194fd50a351c1177c /java/client | |
| parent | f91439713b0990709b1d7e778166e8b7d0d59d8d (diff) | |
| download | qpid-python-63a400540399ad82bc264d98d12c59a29486bbaa.tar.gz | |
QPID-1373: Remove message for unack'd map when acking individual messages. Add test.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@705658 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/client')
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/AMQSession_0_8.java | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_8.java b/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_8.java index d1fb852c06..e5fc36c389 100644 --- a/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_8.java +++ b/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_8.java @@ -102,6 +102,7 @@ public final class AMQSession_0_8 extends AMQSession<BasicMessageConsumer_0_8, B } getProtocolHandler().writeFrame(ackFrame); + _unacknowledgedMessageTags.remove(deliveryTag); } public void sendQueueBind(final AMQShortString queueName, final AMQShortString routingKey, final FieldTable arguments, |