Skip to content

Commit f98ccb5

Browse files
committed
Turned one ex into auto-delete, manually deleted the other
1 parent cbaef5f commit f98ccb5

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -150,7 +150,7 @@ private void runIt() throws IOException {
150150
_channel.queueDeclare(_ticket, queueName, shouldPersist());
151151

152152
String exchangeName = "test completion";
153-
_channel.exchangeDeclare(_ticket, exchangeName, "fanout");
153+
_channel.exchangeDeclare(_ticket, exchangeName, "fanout", false, false, true, null);
154154

155155
if (shouldCommit()) {
156156
_channel.txSelect();

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -486,6 +486,7 @@ public void tryBasicReturn() throws IOException {
486486
drain(1, mq, true);
487487

488488
_ch1.queueDelete(_ticket, mq);
489+
_ch1.exchangeDelete(_ticket, mx);
489490

490491
log("Completed basic.return testing.");
491492
}

0 commit comments

Comments
 (0)