You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ri...@apache.org on 2007/04/19 17:15:26 UTC
svn commit: r530447 -
/incubator/qpid/branches/M2/java/client/src/test/java/org/apache/qpid/test/unit/topic/TopicSessionTest.java
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");