svn commit: r583432 - /incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/test/unit/topic/TopicSessionTest.java

[arnaudsimon]

Author: arnaudsimon
Date: Wed Oct 10 04:15:19 2007
New Revision: 583432

URL: http://svn.apache.org/viewvc?rev=583432&view=rev
Log:
Updated for using QpidTesCase connection

Modified:
    
incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/test/unit/topic/TopicSessionTest.java

Modified: 
incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/test/unit/topic/TopicSessionTest.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/test/unit/topic/TopicSessionTest.java?rev=583432&r1=583431&r2=583432&view=diff
==============================================================================
--- 
incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/test/unit/topic/TopicSessionTest.java
 (original)
+++ 
incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/test/unit/topic/TopicSessionTest.java
 Wed Oct 10 04:15:19 2007
@@ -120,7 +120,7 @@
         {
             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 @@
         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();