Skip to content

Commit 047a24e

Browse files
author
Matthew Sackman
committed
Exchange should be declared durable irregardless of whether it's declared by the producer or consumer (bug surfaced when having -x 0 and then in a separate client doing -y 0).
1 parent 1c1885e commit 047a24e

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -124,7 +124,7 @@ public static void main(String[] args) {
124124
producerConnections[i] = conn;
125125
Channel channel = conn.createChannel();
126126
if (producerTxSize > 0) channel.txSelect();
127-
channel.exchangeDeclare(exchangeName, exchangeType);
127+
channel.exchangeDeclare(exchangeName, exchangeType, false, true, true, null);
128128
Thread t =
129129
new Thread(new Producer(channel, exchangeName, id,
130130
flags, producerTxSize,

0 commit comments

Comments
 (0)