From 9ee844d41387bcdcf7d713c93fe8a38d5951b436 Mon Sep 17 00:00:00 2001 From: Martin Ritchie Date: Sat, 11 Apr 2009 01:37:45 +0000 Subject: Added comments to help understand the test git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@764139 13f79535-47bb-0310-9956-ffa450edef68 --- .../apache/qpid/client/MessageListenerMultiConsumerTest.java | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/java/systests/src/main/java/org/apache/qpid/client/MessageListenerMultiConsumerTest.java b/java/systests/src/main/java/org/apache/qpid/client/MessageListenerMultiConsumerTest.java index b438304892..784943b404 100644 --- a/java/systests/src/main/java/org/apache/qpid/client/MessageListenerMultiConsumerTest.java +++ b/java/systests/src/main/java/org/apache/qpid/client/MessageListenerMultiConsumerTest.java @@ -197,13 +197,15 @@ public class MessageListenerMultiConsumerTest extends QpidTestCase { _logger.info("Performing Receive only with two consumers on one session "); - MessageConsumer consumer2 = _clientSession1.createConsumer(_queue); + //Create a new consumer on session one that we don't use + _clientSession1.createConsumer(_queue); int msg; for (msg = 0; msg < (MSG_COUNT / 2); msg++) { - + // Attempt to receive up to half the messages + // The other half may have gone to the consumer above final Message message = _consumer1.receive(1000); if(message == null) { @@ -213,8 +215,12 @@ public class MessageListenerMultiConsumerTest extends QpidTestCase } _consumer1.close(); + // This will close the unused consumer above. _clientSession1.close(); + + // msg will now have recorded the number received on session 1 + // attempt to retrieve the rest on session 2 for (; msg < MSG_COUNT ; msg++) { assertTrue("Failed at msg id" + msg, _consumer2.receive(1000) != null); -- cgit v1.2.1