summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMartin Ritchie <ritchiem@apache.org>2007-04-19 15:15:25 +0000
committerMartin Ritchie <ritchiem@apache.org>2007-04-19 15:15:25 +0000
commitaf93dbc9e069292f4c6656d579fd94a7ea3ac49e (patch)
tree13656940f14e32c6251e45b1edc0416297172044
parentbeb8918984d1afd7cce01a0d308c5e381bed47bd (diff)
downloadqpid-python-af93dbc9e069292f4c6656d579fd94a7ea3ac49e.tar.gz
Committed test with localhost as the broker
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@530447 13f79535-47bb-0310-9956-ffa450edef68
-rw-r--r--java/client/src/test/java/org/apache/qpid/test/unit/topic/TopicSessionTest.java9
1 files changed, 4 insertions, 5 deletions
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 5003814f32..a19687b07c 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
@@ -41,26 +41,25 @@ import org.apache.qpid.client.transport.TransportConnection;
/** @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");