Skip to content

Commit b6ecf55

Browse files
committed
Changed exhange declaration into auto-delete
1 parent 67d1832 commit b6ecf55

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

test/src/com/rabbitmq/examples/ConsumerMain.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -108,7 +108,7 @@ private void runIt() throws IOException {
108108
channel.queueDeclare(ticket, queueName);
109109

110110
String exchangeName = "test completion";
111-
channel.exchangeDeclare(ticket, exchangeName, "fanout");
111+
channel.exchangeDeclare(ticket, exchangeName, "fanout", false, false, true, null);
112112

113113
String completionQueue = channel.queueDeclare(ticket).getQueue();
114114
channel.queueBind(ticket, completionQueue, exchangeName, "");

0 commit comments

Comments
 (0)