svn commit: r640426 - /incubator/qpid/branches/M2.1/java/systests/src/main/java/org/apache/qpid/test/unit/ack/AcknowledgeTest.java

[aidan]

Author: aidan
Date: Mon Mar 24 07:36:36 2008
New Revision: 640426

URL: http://svn.apache.org/viewvc?rev=640426&view=rev
Log:
QPID-874 use getQueueDepth properly

Modified:
    
incubator/qpid/branches/M2.1/java/systests/src/main/java/org/apache/qpid/test/unit/ack/AcknowledgeTest.java

Modified: 
incubator/qpid/branches/M2.1/java/systests/src/main/java/org/apache/qpid/test/unit/ack/AcknowledgeTest.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/branches/M2.1/java/systests/src/main/java/org/apache/qpid/test/unit/ack/AcknowledgeTest.java?rev=640426&r1=640425&r2=640426&view=diff
==============================================================================
--- 
incubator/qpid/branches/M2.1/java/systests/src/main/java/org/apache/qpid/test/unit/ack/AcknowledgeTest.java
 (original)
+++ 
incubator/qpid/branches/M2.1/java/systests/src/main/java/org/apache/qpid/test/unit/ack/AcknowledgeTest.java
 Mon Mar 24 07:36:36 2008
@@ -33,7 +33,9 @@
 
 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 @@
         _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);