diff options
Diffstat (limited to 'java/client/src/test/java/org/apache/qpid/test/unit/client/AMQConnectionTest.java')
| -rw-r--r-- | java/client/src/test/java/org/apache/qpid/test/unit/client/AMQConnectionTest.java | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/java/client/src/test/java/org/apache/qpid/test/unit/client/AMQConnectionTest.java b/java/client/src/test/java/org/apache/qpid/test/unit/client/AMQConnectionTest.java index 92f30e6478..0e15341615 100644 --- a/java/client/src/test/java/org/apache/qpid/test/unit/client/AMQConnectionTest.java +++ b/java/client/src/test/java/org/apache/qpid/test/unit/client/AMQConnectionTest.java @@ -31,6 +31,7 @@ import org.apache.qpid.client.AMQQueue; import org.apache.qpid.client.AMQSession; import org.apache.qpid.client.AMQTopic; import org.apache.qpid.client.transport.TransportConnection; +import org.apache.qpid.framing.AMQShortString; public class AMQConnectionTest extends TestCase { @@ -45,8 +46,8 @@ public class AMQConnectionTest extends TestCase super.setUp(); TransportConnection.createVMBroker(1); _connection = new AMQConnection("vm://:1", "guest", "guest", "fred", "test"); - _topic = new AMQTopic("mytopic"); - _queue = new AMQQueue("myqueue"); + _topic = new AMQTopic(_connection.getDefaultTopicExchangeName(), new AMQShortString("mytopic")); + _queue = new AMQQueue(_connection.getDefaultQueueExchangeName(), new AMQShortString("myqueue")); } protected void tearDown() throws Exception |