From cdff017c37ca52b07c5f21b60de733b1d5fbe9e3 Mon Sep 17 00:00:00 2001 From: Arnaud Simon Date: Mon, 17 Dec 2007 16:51:18 +0000 Subject: Qpid-709: nolocal test was failing because the inVM connections were not created with a new connection ID. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@604926 13f79535-47bb-0310-9956-ffa450edef68 --- .../org/apache/qpid/test/unit/topic/TopicSessionTest.java | 2 +- .../test/java/org/apache/qpid/testutil/QpidTestCase.java | 15 +++++++++++++++ 2 files changed, 16 insertions(+), 1 deletion(-) (limited to 'qpid/java/client/src/test') diff --git a/qpid/java/client/src/test/java/org/apache/qpid/test/unit/topic/TopicSessionTest.java b/qpid/java/client/src/test/java/org/apache/qpid/test/unit/topic/TopicSessionTest.java index 31862cf5c1..3479dfae03 100644 --- a/qpid/java/client/src/test/java/org/apache/qpid/test/unit/topic/TopicSessionTest.java +++ b/qpid/java/client/src/test/java/org/apache/qpid/test/unit/topic/TopicSessionTest.java @@ -339,7 +339,7 @@ public class TopicSessionTest extends QpidTestCase m = (TextMessage) noLocal.receive(100); assertNull(m); - AMQConnection con2 = (AMQConnection) getConnection("guest", "guest"); + AMQConnection con2 = (AMQConnection) getConnection("guest", "guest", "foo"); TopicSession session2 = con2.createTopicSession(false, AMQSession.NO_ACKNOWLEDGE); TopicPublisher publisher2 = session2.createPublisher(topic); diff --git a/qpid/java/client/src/test/java/org/apache/qpid/testutil/QpidTestCase.java b/qpid/java/client/src/test/java/org/apache/qpid/testutil/QpidTestCase.java index ca9bdee514..094790fb7e 100644 --- a/qpid/java/client/src/test/java/org/apache/qpid/testutil/QpidTestCase.java +++ b/qpid/java/client/src/test/java/org/apache/qpid/testutil/QpidTestCase.java @@ -238,4 +238,19 @@ public class QpidTestCase extends TestCase } return con; } + + public Connection getConnection(String username, String password, String id) throws Exception + { + _logger.info("get Connection"); + Connection con; + if (_shel.equals(BROKER_VM)) + { + con = new AMQConnection("vm://:1", username, password, id, "test"); + } + else + { + con = getConnectionFactory().createConnection(username, password); + } + return con; + } } -- cgit v1.2.1