Skip to content

Commit 1820704

Browse files
committed
always create auto-delete, non-exclusive queues
since as of bug25276, exclusive durable queues no longer persist messages, which made PerfTest somewhat less versatile than it used to be.
1 parent 52e996f commit 1820704

File tree

1 file changed

+2
-4
lines changed

1 file changed

+2
-4
lines changed

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

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -70,8 +70,6 @@ public static void main(String[] args) {
7070

7171
String uri = strArg(cmd, 'h', "amqp://localhost");
7272

73-
boolean exclusive = "".equals(queueName);
74-
7573
//setup
7674
PrintlnStats stats = new PrintlnStats(1000L * samplingInterval,
7775
producerCount > 0,
@@ -88,14 +86,14 @@ public static void main(String[] args) {
8886

8987
MulticastParams p = new MulticastParams();
9088
p.setAutoAck( autoAck);
91-
p.setAutoDelete( !exclusive);
89+
p.setAutoDelete( true);
9290
p.setConfirm( confirm);
9391
p.setConsumerCount( consumerCount);
9492
p.setConsumerMsgCount( consumerMsgCount);
9593
p.setConsumerTxSize( consumerTxSize);
9694
p.setExchangeName( exchangeName);
9795
p.setExchangeType( exchangeType);
98-
p.setExclusive( exclusive);
96+
p.setExclusive( false);
9997
p.setFlags( flags);
10098
p.setMultiAckEvery( multiAckEvery);
10199
p.setMinMsgSize( minMsgSize);

0 commit comments

Comments
 (0)