diff options
Diffstat (limited to 'java/tools/src/main/java/org/apache/qpid/testkit/TestLauncher.java')
-rw-r--r-- | java/tools/src/main/java/org/apache/qpid/testkit/TestLauncher.java | 9 |
1 files changed, 2 insertions, 7 deletions
diff --git a/java/tools/src/main/java/org/apache/qpid/testkit/TestLauncher.java b/java/tools/src/main/java/org/apache/qpid/testkit/TestLauncher.java index 72ca48e1c9..2d93daa3b2 100644 --- a/java/tools/src/main/java/org/apache/qpid/testkit/TestLauncher.java +++ b/java/tools/src/main/java/org/apache/qpid/testkit/TestLauncher.java @@ -29,9 +29,7 @@ import java.text.NumberFormat; import java.text.SimpleDateFormat; import java.util.ArrayList; import java.util.Date; -import java.util.HashMap; import java.util.List; -import java.util.Map; import javax.jms.Destination; import javax.jms.JMSException; @@ -44,11 +42,8 @@ import org.apache.log4j.ConsoleAppender; import org.apache.log4j.Level; import org.apache.log4j.Logger; import org.apache.log4j.PatternLayout; -import org.apache.qpid.client.AMQAnyDestination; import org.apache.qpid.client.AMQConnection; -import org.apache.qpid.client.AMQQueue; -import org.apache.qpid.client.AMQTopic; -import org.apache.qpid.framing.AMQShortString; +import org.apache.qpid.client.AddressBasedDestination; import org.apache.qpid.thread.Threading; /** @@ -144,7 +139,7 @@ public class TestLauncher implements ErrorHandler controlCon = new AMQConnection(url); controlCon.start(); - controlDest = new AMQAnyDestination("control; {create: always}"); // durable + controlDest = new AddressBasedDestination("control; {create: always}"); // durable // Create the session to setup the messages controlSession = controlCon.createSession(false, Session.AUTO_ACKNOWLEDGE); |