svn commit: r530447 - /incubator/qpid/branches/M2/java/client/src/test/java/org/apache/qpid/test/unit/topic/TopicSessionTest.java

[ritchiem]

Author: ritchiem
Date: Thu Apr 19 08:15:25 2007
New Revision: 530447

URL: http://svn.apache.org/viewvc?view=rev&rev=530447
Log:
Committed test with localhost as the broker

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

Modified: 
incubator/qpid/branches/M2/java/client/src/test/java/org/apache/qpid/test/unit/topic/TopicSessionTest.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/branches/M2/java/client/src/test/java/org/apache/qpid/test/unit/topic/TopicSessionTest.java?view=diff&rev=530447&r1=530446&r2=530447
==============================================================================
--- 
incubator/qpid/branches/M2/java/client/src/test/java/org/apache/qpid/test/unit/topic/TopicSessionTest.java
 (original)
+++ 
incubator/qpid/branches/M2/java/client/src/test/java/org/apache/qpid/test/unit/topic/TopicSessionTest.java
 Thu Apr 19 08:15:25 2007
@@ -41,26 +41,25 @@
 /** @author Apache Software Foundation */
 public class TopicSessionTest extends TestCase
 {
-    private static final String BROKER = "localhost";
+    private static final String BROKER = "vm://:1";
 
     protected void setUp() throws Exception
     {
         super.setUp();
-//        TransportConnection.createVMBroker(1);
+        TransportConnection.createVMBroker(1);
     }
 
     protected void tearDown() throws Exception
     {
         super.tearDown();
-//        TransportConnection.killAllVMBrokers();
-        //Thread.sleep(2000);
+        TransportConnection.killAllVMBrokers();
     }
 
 
     public void testTopicSubscriptionUnsubscription() throws Exception
     {
 
-        AMQConnection con = new AMQConnection("vm://:1?retries='0'", "guest", 
"guest", "test", "test");
+        AMQConnection con = new AMQConnection(BROKER+"?retries='0'", "guest", 
"guest", "test", "test");
         AMQTopic topic = new AMQTopic(con.getDefaultTopicExchangeName(), 
"MyTopic");
         TopicSession session1 = con.createTopicSession(false, 
AMQSession.NO_ACKNOWLEDGE);
         TopicSubscriber sub = session1.createDurableSubscriber(topic, 
"subscription0");