From c4bb61aa77aaa98fa697f1679bc23a16a6f10b19 Mon Sep 17 00:00:00 2001 From: Arnaud Simon Date: Wed, 10 Oct 2007 11:15:19 +0000 Subject: Updated for using QpidTesCase connection git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@583432 13f79535-47bb-0310-9956-ffa450edef68 --- .../test/java/org/apache/qpid/test/unit/topic/TopicSessionTest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'java/client') diff --git a/java/client/src/test/java/org/apache/qpid/test/unit/topic/TopicSessionTest.java b/java/client/src/test/java/org/apache/qpid/test/unit/topic/TopicSessionTest.java index 94e8b1fe29..31862cf5c1 100644 --- a/java/client/src/test/java/org/apache/qpid/test/unit/topic/TopicSessionTest.java +++ b/java/client/src/test/java/org/apache/qpid/test/unit/topic/TopicSessionTest.java @@ -120,7 +120,7 @@ public class TopicSessionTest extends QpidTestCase { session1.close(); con.close(); - con = new AMQConnection("vm://:1?retries='0'", "guest", "guest", "test", "test"); + con = (AMQConnection) getConnection("guest", "guest"); con.start(); session1 = con.createTopicSession(false, AMQSession.NO_ACKNOWLEDGE); publisher = session1.createPublisher(null); @@ -158,7 +158,7 @@ public class TopicSessionTest extends QpidTestCase assertNotNull(tm); con2.close(); publisher.publish(session1.createTextMessage("Hello2")); - con2 = new AMQConnection("vm://:1?retries='0'", "guest", "guest", "test2", "test"); + con2 = (AMQConnection) getConnection("guest", "guest"); session2 = con2.createTopicSession(false, AMQSession.NO_ACKNOWLEDGE); sub = session2.createDurableSubscriber(topic, "subscription0"); con2.start(); -- cgit v1.2.1