summaryrefslogtreecommitdiff
path: root/qpid/java/cluster/src
diff options
context:
space:
mode:
Diffstat (limited to 'qpid/java/cluster/src')
-rw-r--r--qpid/java/cluster/src/test/java/org/apache/qpid/server/cluster/SimpleClusterTest.java2
1 files changed, 1 insertions, 1 deletions
diff --git a/qpid/java/cluster/src/test/java/org/apache/qpid/server/cluster/SimpleClusterTest.java b/qpid/java/cluster/src/test/java/org/apache/qpid/server/cluster/SimpleClusterTest.java
index 70209cd2a3..86cde3cee7 100644
--- a/qpid/java/cluster/src/test/java/org/apache/qpid/server/cluster/SimpleClusterTest.java
+++ b/qpid/java/cluster/src/test/java/org/apache/qpid/server/cluster/SimpleClusterTest.java
@@ -37,7 +37,7 @@ public class SimpleClusterTest extends TestCase
AMQConnection con = new AMQConnection("localhost:9000", "guest", "guest", "test", "/test");
AMQSession session = (AMQSession) con.createSession(false, AMQSession.NO_ACKNOWLEDGE);
System.out.println("Session created");
- session.declareExchange(new AMQShortString("my_exchange"), new AMQShortString("direct"));
+ session.declareExchange(new AMQShortString("my_exchange"), new AMQShortString("direct"), true);
System.out.println("Exchange declared");
con.close();
System.out.println("Connection closed");