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

1 files changed, 16 insertions, 0 deletions

diff --git a/java/systests/src/main/java/org/apache/qpid/test/unit/ack/AcknowledgeTest.java b/java/systests/src/main/java/org/apache/qpid/test/unit/ack/AcknowledgeTest.java
index d0814ca5fc..b63f990791 100644
--- a/java/systests/src/main/java/org/apache/qpid/test/unit/ack/AcknowledgeTest.java
+++ b/java/systests/src/main/java/org/apache/qpid/test/unit/ack/AcknowledgeTest.java
@@ -31,6 +31,7 @@ import javax.jms.Session;
 
 import org.apache.qpid.client.AMQDestination;
 import org.apache.qpid.client.AMQSession;
+import org.apache.qpid.client.message.AbstractJMSMessage;
 import org.apache.qpid.test.utils.QpidTestCase;
 
 public class AcknowledgeTest extends QpidTestCase
@@ -141,4 +142,19 @@ public class AcknowledgeTest extends QpidTestCase
     	testMessageAck(true, Session.AUTO_ACKNOWLEDGE);
     }
     
+    public void testIndividualAck() throws Exception
+    {
+        init(false, Session.CLIENT_ACKNOWLEDGE);
+        sendMessages(3);
+        Message msg = null;
+        for (int i = 0; i < 2; i++)
+        {
+            msg = _consumerA.receive(RECEIVE_TIMEOUT);
+            ((AbstractJMSMessage)msg).acknowledgeThis();
+        }
+        msg = _consumerA.receive(RECEIVE_TIMEOUT);
+        msg.acknowledge();
+        _con.close();
+    }
+    
 }