diff options
| author | Keith Wall <kwall@apache.org> | 2015-02-12 12:00:06 +0000 |
|---|---|---|
| committer | Keith Wall <kwall@apache.org> | 2015-02-12 12:00:06 +0000 |
| commit | 825aceb7e885c793309557a3a886f10c475c4c1c (patch) | |
| tree | 11a5b5926a714c956f6cd77f56b373e96755df13 /qpid/java/systests/src | |
| parent | 5701b4ba67b8e475326acfc9f28735aead8d9dfc (diff) | |
| download | qpid-python-825aceb7e885c793309557a3a886f10c475c4c1c.tar.gz | |
broswer consumer close is now pulled by IO rather than pushed by queue, fixing browser tests
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1659232 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/systests/src')
| -rw-r--r-- | qpid/java/systests/src/test/java/org/apache/qpid/test/client/QueueBrowserAutoAckTest.java | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/qpid/java/systests/src/test/java/org/apache/qpid/test/client/QueueBrowserAutoAckTest.java b/qpid/java/systests/src/test/java/org/apache/qpid/test/client/QueueBrowserAutoAckTest.java index 6b6b4a7b3c..8a4e22783f 100644 --- a/qpid/java/systests/src/test/java/org/apache/qpid/test/client/QueueBrowserAutoAckTest.java +++ b/qpid/java/systests/src/test/java/org/apache/qpid/test/client/QueueBrowserAutoAckTest.java @@ -148,7 +148,6 @@ public class QueueBrowserAutoAckTest extends QpidBrokerTestCase assertEquals("Session reports Queue expectedDepth not as expected", expectedDepth, queueDepth); - // Browse the queue to get a second opinion int msgCount = 0; Enumeration msgs = queueBrowser.getEnumeration(); @@ -268,7 +267,7 @@ public class QueueBrowserAutoAckTest extends QpidBrokerTestCase //validate all browsers get right message count. for (int count = 0; count < browserEnumerationCount; count++) { - assertEquals(msgCount[count], expectedMessages); + assertEquals("Unexpected count for browser " + count, expectedMessages, msgCount[count]); } try @@ -317,7 +316,7 @@ public class QueueBrowserAutoAckTest extends QpidBrokerTestCase //Close this new connection connection.close(); - _logger.info("All messages recevied from queue"); + _logger.info("All messages received from queue"); //ensure no message left. checkQueueDepth(0); @@ -344,7 +343,7 @@ public class QueueBrowserAutoAckTest extends QpidBrokerTestCase /* * Test Messages Remain on Queue - * Create a queu and send messages to it. Browse them and then receive them all to verify they were still there + * Create a queue and send messages to it. Browse them and then receive them all to verify they were still there * */ public void testQueueBrowserMsgsRemainOnQueue() throws Exception |