Skip to content

Commit fd30317

Browse files
author
Alexandru Scvortov
committed
ConfirmDontLoseMessages: delete queue when done
1 parent 7e6d920 commit fd30317

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

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

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -99,6 +99,7 @@ public void handleAck(long seqNo,
9999
Thread.sleep(10);
100100

101101
// Cleanup
102+
ch.queueDelete(QUEUE_NAME);
102103
ch.close();
103104
conn.close();
104105

@@ -127,7 +128,7 @@ public void run() {
127128
qc.nextDelivery();
128129
}
129130

130-
// Consume
131+
// Cleanup
131132
ch.close();
132133
conn.close();
133134
} catch (Throwable e) {

0 commit comments

Comments
 (0)