From d1b055801ad6f433e75fc57bf835126494a3eeef Mon Sep 17 00:00:00 2001 From: Rajith Muditha Attapattu Date: Mon, 3 May 2010 23:35:56 +0000 Subject: Removed assertions based on wrong assumptions. The c++ broker does not make any guarantees about how it distributes the messages among consumers on a single queue. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@940674 13f79535-47bb-0310-9956-ffa450edef68 --- .../apache/qpid/test/unit/client/AMQConnectionTest.java | 15 +++++++-------- 1 file changed, 7 insertions(+), 8 deletions(-) (limited to 'qpid/java') diff --git a/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/client/AMQConnectionTest.java b/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/client/AMQConnectionTest.java index 0ab4e33f30..78240dde71 100644 --- a/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/client/AMQConnectionTest.java +++ b/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/client/AMQConnectionTest.java @@ -213,27 +213,26 @@ public class AMQConnectionTest extends QpidTestCase // Send 3 messages for (int i = 0; i < 3; i++) { - producer.send(producerSession.createTextMessage(new Integer(i).toString())); + producer.send(producerSession.createTextMessage("test")); } + Session consSessB = _connection.createSession(true, Session.AUTO_ACKNOWLEDGE); MessageConsumer consumerB = consSessB.createConsumer(_queue); Message msg; - // Check that one consumer has 2 messages + // Check that consumer A has 2 messages for (int i = 0; i < 2; i++) { msg = consumerA.receive(1500); - assertNotNull(msg); - assertEquals(new Integer(i).toString(), ((TextMessage) msg).getText()); + assertNotNull("Consumer A should receive 2 messages",msg); } msg = consumerA.receive(1500); - assertNull(msg); + assertNull("Consumer A should not have received a 3rd message",msg); - // Check that other consumer has last message + // Check that consumer B has the last message msg = consumerB.receive(1500); - assertNotNull(msg); - assertEquals(new Integer(2).toString(), ((TextMessage) msg).getText()); + assertNotNull("Consumer B should have received the message",msg); } finally { -- cgit v1.2.1