QPID-874 use getQueueDepth properly

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@640426 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 4 insertions, 1 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 fd76ea2ec8..8fddf651b4 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
@@ -33,7 +33,9 @@ import javax.jms.TextMessage;
 
 import org.apache.log4j.Logger;
 import org.apache.qpid.client.AMQConnectionFactory;
+import org.apache.qpid.client.AMQDestination;
 import org.apache.qpid.client.AMQQueue;
+import org.apache.qpid.client.AMQSession;
 import org.apache.qpid.client.transport.TransportConnection;
 import org.apache.qpid.server.registry.ApplicationRegistry;
 import org.apache.qpid.test.VMTestCase;
@@ -130,7 +132,8 @@ public class AcknowledgeTest extends VMTestCase
         _consumerA.close();
         _consumerB.close();
         _consumerSession.close();
-        assertEquals("Wrong number of messages on queue", NUM_MESSAGES - count, getMessageCount(_queue.getQueueName()));
+        assertEquals("Wrong number of messages on queue", NUM_MESSAGES - count,
+                        ((AMQSession) _producerSession).getQueueDepth((AMQDestination) _queue));
 
         // Clean up messages that may be left on the queue
         _consumerSession = _con.createSession(transacted, mode);