diff options
Diffstat (limited to 'java/client/src/test/java/org/apache/qpid/testutil/Config.java')
-rw-r--r-- | java/client/src/test/java/org/apache/qpid/testutil/Config.java | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/java/client/src/test/java/org/apache/qpid/testutil/Config.java b/java/client/src/test/java/org/apache/qpid/testutil/Config.java index ad51fe498d..e5b4834622 100644 --- a/java/client/src/test/java/org/apache/qpid/testutil/Config.java +++ b/java/client/src/test/java/org/apache/qpid/testutil/Config.java @@ -27,6 +27,7 @@ import org.apache.qpid.client.AMQConnection; import org.apache.qpid.client.AMQHeadersExchange; import org.apache.qpid.client.AMQQueue; import org.apache.qpid.client.AMQTopic; +import org.apache.qpid.exchange.ExchangeDefaults; public class Config { @@ -117,12 +118,12 @@ public class Config if(isQueue()) { System.out.println("Using queue named " + name); - return new AMQQueue(name); + return new AMQQueue(ExchangeDefaults.DIRECT_EXCHANGE_NAME,name); } else if(isTopic()) { System.out.println("Using topic named " + name); - return new AMQTopic(name); + return new AMQTopic(ExchangeDefaults.TOPIC_EXCHANGE_NAME,name); } else if(isHeaders()) { |