summaryrefslogtreecommitdiff
path: root/java/client/src/test/java/org/apache/qpid/testutil/Config.java
diff options
context:
space:
mode:
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.java5
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())
{