summaryrefslogtreecommitdiff
path: root/java/client/src/test
diff options
context:
space:
mode:
authorArnaud Simon <arnaudsimon@apache.org>2007-10-01 16:32:45 +0000
committerArnaud Simon <arnaudsimon@apache.org>2007-10-01 16:32:45 +0000
commit3ac5711925afbcc8be4800deb6e53a3f43e5b310 (patch)
tree1baf35d7ef86528a75b9a3196390999a9b381cb2 /java/client/src/test
parenta255b35b435013061783a8032bb0060216305210 (diff)
downloadqpid-python-3ac5711925afbcc8be4800deb6e53a3f43e5b310.tar.gz
Changed to use QpidTestCase
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@581008 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/client/src/test')
-rw-r--r--java/client/src/test/java/org/apache/qpid/test/unit/basic/MultipleConnectionTest.java11
1 files changed, 6 insertions, 5 deletions
diff --git a/java/client/src/test/java/org/apache/qpid/test/unit/basic/MultipleConnectionTest.java b/java/client/src/test/java/org/apache/qpid/test/unit/basic/MultipleConnectionTest.java
index 65b3d60ad9..4bee2ab691 100644
--- a/java/client/src/test/java/org/apache/qpid/test/unit/basic/MultipleConnectionTest.java
+++ b/java/client/src/test/java/org/apache/qpid/test/unit/basic/MultipleConnectionTest.java
@@ -27,6 +27,7 @@ import org.apache.qpid.client.AMQSession;
import org.apache.qpid.client.AMQTopic;
import org.apache.qpid.client.transport.TransportConnection;
import org.apache.qpid.exchange.ExchangeDefaults;
+import org.apache.qpid.testutil.QpidTestCase;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -37,14 +38,14 @@ import javax.jms.MessageListener;
import javax.jms.MessageProducer;
import javax.jms.Session;
-public class MultipleConnectionTest extends TestCase
+public class MultipleConnectionTest extends QpidTestCase
{
private static final Logger _logger = LoggerFactory.getLogger(MultipleConnectionTest.class);
public static final String _defaultBroker = "vm://:1";
public String _connectionString = _defaultBroker;
- private static class Receiver
+ private class Receiver
{
private AMQConnection _connection;
private Session[] _sessions;
@@ -52,7 +53,7 @@ public class MultipleConnectionTest extends TestCase
Receiver(String broker, AMQDestination dest, int sessions) throws Exception
{
- this(new AMQConnection(broker, "guest", "guest", randomize("Client"), "test"), dest, sessions);
+ this((AMQConnection) getConnection("guest", "guest"), dest, sessions);
}
Receiver(AMQConnection connection, AMQDestination dest, int sessions) throws Exception
@@ -76,7 +77,7 @@ public class MultipleConnectionTest extends TestCase
}
}
- private static class Publisher
+ private class Publisher
{
private AMQConnection _connection;
private Session _session;
@@ -84,7 +85,7 @@ public class MultipleConnectionTest extends TestCase
Publisher(String broker, AMQDestination dest) throws Exception
{
- this(new AMQConnection(broker, "guest", "guest", randomize("Client"), "test"), dest);
+ this((AMQConnection) getConnection("guest", "guest"), dest);
}
Publisher(AMQConnection connection, AMQDestination dest) throws Exception