From 1e9323d2d2ba0228e550a1cec08268171354b55f Mon Sep 17 00:00:00 2001 From: Kim van der Riet Date: Fri, 26 Jan 2007 14:40:48 +0000 Subject: Change to TransactedTest which privents the intermittent error junit.framework.ComparisonFailure: expected: but was: (or similar) from occurring on either the commit or rollback portion of the test. The error occurs when the test consumer testConsumer1 bind frames arrive at the server before the message bodies with A,B,C and cause queue 1 to start a round-robin distribution for these messages when they finally do arrive. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@500263 13f79535-47bb-0310-9956-ffa450edef68 --- .../test/java/org/apache/qpid/test/unit/transacted/TransactedTest.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) (limited to 'java/client') diff --git a/java/client/src/test/java/org/apache/qpid/test/unit/transacted/TransactedTest.java b/java/client/src/test/java/org/apache/qpid/test/unit/transacted/TransactedTest.java index 90a11307b8..88e79505c8 100644 --- a/java/client/src/test/java/org/apache/qpid/test/unit/transacted/TransactedTest.java +++ b/java/client/src/test/java/org/apache/qpid/test/unit/transacted/TransactedTest.java @@ -76,7 +76,6 @@ public class TransactedTest extends TestCase testCon = new AMQConnection("vm://:1", "guest", "guest", "TestConnection", "/test"); testSession = testCon.createSession(false, AMQSession.NO_ACKNOWLEDGE); - testConsumer1 = testSession.createConsumer(queue1); testConsumer2 = testSession.createConsumer(queue2); testCon.start(); } @@ -107,6 +106,7 @@ public class TransactedTest extends TestCase expect("Y", testConsumer2.receive(1000)); expect("Z", testConsumer2.receive(1000)); + testConsumer1 = testSession.createConsumer(queue1); assertTrue(null == testConsumer1.receive(1000)); assertTrue(null == testConsumer2.receive(1000)); } @@ -128,6 +128,7 @@ public class TransactedTest extends TestCase expect("B", consumer1.receive(1000)); expect("C", consumer1.receive(1000)); + testConsumer1 = testSession.createConsumer(queue1); assertTrue(null == testConsumer1.receive(1000)); assertTrue(null == testConsumer2.receive(1000)); } -- cgit v1.2.1