because we now only write out persistent messages sent to a durable queue, we must make the queue durable and also, due to the 0.8 spec, the exchange durable.

Author: Matthew Sackman

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

@@ -102,8 +102,8 @@ public static void main(String[] args) {
                 consumerConnections[i] = conn;
                 Channel channel = conn.createChannel();
                 if (consumerTxSize > 0) channel.txSelect();
-                channel.exchangeDeclare(exchangeName, exchangeType);
-                Queue.DeclareOk res = channel.queueDeclare();
+                channel.exchangeDeclare(exchangeName, exchangeType, false, true, true, null);
+                Queue.DeclareOk res = channel.queueDeclare("", false, true, true, true, null);
                 String queueName = res.getQueue();
                 QueueingConsumer consumer = new QueueingConsumer(channel);
                 if (prefetchCount > 0) channel.basicQos(prefetchCount);