Always make the consumermain/producermain queue durable.

Author: tonyg

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

@@ -110,7 +110,7 @@ private void runIt() throws IOException {
         Channel channel = _connection.createChannel();
 
         String queueName = "test queue";
-        channel.queueDeclare(queueName);
+        channel.queueDeclare(queueName, true);
 
         String exchangeName = "test completion";
         channel.exchangeDeclare(exchangeName, "fanout", false, false, true, null);

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

@@ -150,7 +150,7 @@ private void runIt() throws IOException {
         _channel = _connection.createChannel();
 
         String queueName = "test queue";
-        _channel.queueDeclare(queueName, shouldPersist());
+        _channel.queueDeclare(queueName, true);
 
         if (shouldCommit()) {
             _channel.txSelect();