From 82f0dd0fc5395e4a8fdc2a0839b38988623f32e8 Mon Sep 17 00:00:00 2001 From: Aidan Skinner Date: Mon, 24 Mar 2008 14:36:36 +0000 Subject: 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 --- .../src/main/java/org/apache/qpid/test/unit/ack/AcknowledgeTest.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) (limited to 'java') 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); -- cgit v1.2.1