From 9ffd924daedfc7d1d3c2e072befaf6645aef671e Mon Sep 17 00:00:00 2001 From: Kim van der Riet Date: Thu, 15 Feb 2007 15:23:55 +0000 Subject: Fixes to get TransactedTest back, there are still unresolved issues with rollback(), however. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@507960 13f79535-47bb-0310-9956-ffa450edef68 --- .../qpid/test/unit/transacted/TransactedTest.java | 21 +++++++-------------- 1 file changed, 7 insertions(+), 14 deletions(-) (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 ce6df83baf..456763bba0 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 @@ -59,7 +59,7 @@ public class TransactedTest extends TestCase super.setUp(); TransportConnection.createVMBroker(1); queue1 = new AMQQueue(new AMQShortString("Q1"), new AMQShortString("Q1"), false, true); - queue2 = new AMQQueue("Q2", false); + queue2 = new AMQQueue("Q2x", false); con = new AMQConnection("vm://:1", "guest", "guest", "TransactedTest", "test"); session = con.createSession(true, 0); @@ -74,15 +74,6 @@ public class TransactedTest extends TestCase prepSession = prepCon.createSession(false, AMQSession.NO_ACKNOWLEDGE); prepProducer1 = prepSession.createProducer(queue1); prepCon.start(); - -// //add some messages -// prepProducer1.send(prepSession.createTextMessage("A")); -// prepProducer1.send(prepSession.createTextMessage("B")); -// prepProducer1.send(prepSession.createTextMessage("C")); -// -// testCon = new AMQConnection("vm://:1", "guest", "guest", "TestConnection", "/test"); -// testSession = testCon.createSession(false, AMQSession.NO_ACKNOWLEDGE); -// testConsumer2 = testSession.createConsumer(queue2); } protected void tearDown() throws Exception @@ -110,8 +101,9 @@ public class TransactedTest extends TestCase //commit session.commit(); - testCon.start(); + //ensure sent messages can be received and received messages are gone + testCon = new AMQConnection("vm://:1", "guest", "guest", "TestConnection", "test"); testSession = testCon.createSession(false, AMQSession.NO_ACKNOWLEDGE); testConsumer1 = testSession.createConsumer(queue1); @@ -156,10 +148,10 @@ public class TransactedTest extends TestCase expect("A", consumer1.receive(1000)); expect("B", consumer1.receive(1000)); expect("C", consumer1.receive(1000)); - testCon.start(); - testConsumer1 = testSession.createConsumer(queue1); + //commit - session.commit(); + //session.commit(); + testCon = new AMQConnection("vm://:1", "guest", "guest", "TestConnection", "test"); testSession = testCon.createSession(false, AMQSession.NO_ACKNOWLEDGE); @@ -175,6 +167,7 @@ public class TransactedTest extends TestCase // messages left over from the last test (which can affect later tests)... public void testEmpty2() throws Exception { +//System.out.println("=== DEBUG === testEmpty2(): assertTrue(null == consumer1.receive(1000));"); assertTrue(null == consumer1.receive(1000)); } -- cgit v1.2.1