diff options
| -rw-r--r-- | java/systests/src/main/java/org/apache/qpid/test/unit/ack/AcknowledgeTest.java | 5 |
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); |