diff options
author | Martin Ritchie <ritchiem@apache.org> | 2007-04-02 10:55:12 +0000 |
---|---|---|
committer | Martin Ritchie <ritchiem@apache.org> | 2007-04-02 10:55:12 +0000 |
commit | d257ce9148e6261cdba5e3c6d1d11b56fc317741 (patch) | |
tree | d4212d716e34582b09178327b23b270af61fb530 | |
parent | 8262caa8f97617d97f6dc9ad62bf7319566ec900 (diff) | |
download | qpid-python-d257ce9148e6261cdba5e3c6d1d11b56fc317741.tar.gz |
Moved broker details to a separate variable.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@524765 13f79535-47bb-0310-9956-ffa450edef68
-rw-r--r-- | java/client/src/test/java/org/apache/qpid/test/unit/transacted/CommitRollbackTest.java | 14 |
1 files changed, 10 insertions, 4 deletions
diff --git a/java/client/src/test/java/org/apache/qpid/test/unit/transacted/CommitRollbackTest.java b/java/client/src/test/java/org/apache/qpid/test/unit/transacted/CommitRollbackTest.java index 2abc139ced..ecc22a0846 100644 --- a/java/client/src/test/java/org/apache/qpid/test/unit/transacted/CommitRollbackTest.java +++ b/java/client/src/test/java/org/apache/qpid/test/unit/transacted/CommitRollbackTest.java @@ -53,12 +53,15 @@ public class CommitRollbackTest extends TestCase Queue _jmsQueue; private static final Logger _logger = Logger.getLogger(CommitRollbackTest.class); + private static final String BROKER = "vm://:1"; protected void setUp() throws Exception { super.setUp(); - TransportConnection.createVMBroker(1); - + if (BROKER.startsWith("vm")) + { + TransportConnection.createVMBroker(1); + } testMethod++; queue += testMethod; @@ -68,7 +71,7 @@ public class CommitRollbackTest extends TestCase private void newConnection() throws AMQException, URLSyntaxException, JMSException { - conn = new AMQConnection("amqp://guest:guest@client/test?brokerlist='vm://:1'"); + conn = new AMQConnection("amqp://guest:guest@client/test?brokerlist='" + BROKER + "'"); _session = conn.createSession(true, Session.CLIENT_ACKNOWLEDGE); @@ -87,7 +90,10 @@ public class CommitRollbackTest extends TestCase super.tearDown(); conn.close(); - TransportConnection.killVMBroker(1); + if (BROKER.startsWith("vm")) + { + TransportConnection.killVMBroker(1); + } } /** |