qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From arnaudsi...@apache.org
Subject svn commit: r581008 - /incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/test/unit/basic/MultipleConnectionTest.java
Date Mon, 01 Oct 2007 16:32:47 GMT
Author: arnaudsimon
Date: Mon Oct  1 09:32:45 2007
New Revision: 581008

URL: http://svn.apache.org/viewvc?rev=581008&view=rev
Log:
Changed to use QpidTestCase

Modified:
    incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/test/unit/basic/MultipleConnectionTest.java

Modified: incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/test/unit/basic/MultipleConnectionTest.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/test/unit/basic/MultipleConnectionTest.java?rev=581008&r1=581007&r2=581008&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/test/unit/basic/MultipleConnectionTest.java
(original)
+++ incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/test/unit/basic/MultipleConnectionTest.java
Mon Oct  1 09:32:45 2007
@@ -27,6 +27,7 @@
 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.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 @@
 
         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 @@
         }
     }
 
-    private static class Publisher
+    private class Publisher
     {
         private AMQConnection _connection;
         private Session _session;
@@ -84,7 +85,7 @@
 
         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



Mime
View raw message