diff options
| author | Arnaud Simon <arnaudsimon@apache.org> | 2007-10-01 16:32:45 +0000 |
|---|---|---|
| committer | Arnaud Simon <arnaudsimon@apache.org> | 2007-10-01 16:32:45 +0000 |
| commit | 3ac5711925afbcc8be4800deb6e53a3f43e5b310 (patch) | |
| tree | 1baf35d7ef86528a75b9a3196390999a9b381cb2 /java/client/src/test | |
| parent | a255b35b435013061783a8032bb0060216305210 (diff) | |
| download | qpid-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.java | 11 |
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 |
