Ensure queues have unique names. Make them exclusive (previously they were autodelete but exclusive seems to make more sense). Only make them durable if messages are persistent (slight ugliness when running separate processes).

Author: Simon MacMullen

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

@@ -105,8 +105,9 @@ public static void main(String[] args) {
                 Channel channel = conn.createChannel();
                 if (consumerTxSize > 0) channel.txSelect();
                 channel.exchangeDeclare(exchangeName, exchangeType);
-                String queueName = "consumer-" + i;
-                channel.queueDeclare(queueName, true, false, false, null);
+                String queueName = "consumer-" + UUID.randomUUID();
+                channel.queueDeclare(queueName, flags.contains("persistent"),
+                                     true, false, null);
                 QueueingConsumer consumer = new QueueingConsumer(channel);
                 if (prefetchCount > 0) channel.basicQos(prefetchCount);
                 channel.basicConsume(queueName, autoAck, consumer);