Code tidied wrt Steve's QA bug23639

Author: Ann

java/Recv.java

@@ -1,26 +1,32 @@
+import java.io.IOException;
 import com.rabbitmq.client.ConnectionFactory;
 import com.rabbitmq.client.Connection;
 import com.rabbitmq.client.Channel;
 import com.rabbitmq.client.QueueingConsumer;
 
 public class Recv {
+	
+    private final static String QUEUE_NAME = "hello";
+
     public static void main(String[] argv)
         throws java.io.IOException,
                java.lang.InterruptedException {
-    Connection conn = null;
+
     ConnectionFactory factory = new ConnectionFactory();
     factory.setHost("localhost");
-    conn = factory.newConnection();
-    Channel chan = conn.createChannel();
-
-    chan.queueDeclare("hello", false, false, false, null);
+    Connection connection = factory.newConnection();
+    Channel channel = connection.createChannel();
 
+    channel.queueDeclare(QUEUE_NAME, false, false, false, null);
     System.out.println(" [*] Waiting for messages. To exit press CTRL+C");
-    QueueingConsumer consumer = new QueueingConsumer(chan);
-    chan.basicConsume("hello", true, consumer);
+    
+    QueueingConsumer consumer = new QueueingConsumer(channel);
+    channel.basicConsume(QUEUE_NAME, true, consumer);
+    
     while (true) {
       QueueingConsumer.Delivery delivery = consumer.nextDelivery();
-      System.out.println(" [x] Received " + new String(delivery.getBody()));
+      String message = new String(delivery.getBody());
+      System.out.println(" [x] Received '" + message + "'");
     }
   }
-}
+}

java/Send.java

@@ -1,21 +1,26 @@
+import java.io.IOException;
 import com.rabbitmq.client.ConnectionFactory;
 import com.rabbitmq.client.Connection;
 import com.rabbitmq.client.Channel;
 
 public class Send {
+	
+  private final static String QUEUE_NAME = "hello";
+
   public static void main(String[] argv)
       throws java.io.IOException {
-    Connection conn = null;
+      	      
     ConnectionFactory factory = new ConnectionFactory();
     factory.setHost("localhost");
-    conn = factory.newConnection();
-    Channel chan = conn.createChannel();
-
-    chan.queueDeclare("hello", false, false, false, null);
+    Connection connection = factory.newConnection();
+    Channel channel = connection.createChannel();
 
-    chan.basicPublish("", "hello", null, "Hello World!".getBytes());
-    System.out.println(" [x] Sent 'Hello World!'");
-    chan.close();
-    conn.close();
+    channel.queueDeclare(QUEUE_NAME, false, false, false, null);
+    String message = "Hello World!";
+    channel.basicPublish("", QUEUE_NAME, null, message.getBytes());
+    System.out.println(" [x] Sent '" + message + "'");
+    
+    channel.close();
+    connection.close();
   }
-}
+}

java/Worker.java

@@ -27,10 +27,10 @@ public static void main(String[] argv)
 
     while (true) {
       QueueingConsumer.Delivery delivery = consumer.nextDelivery();
-      String body = new String(delivery.getBody());
+      String message = new String(delivery.getBody());
 
-      System.out.println(" [x] Received '" + body + "'");
-      doWork(body);
+      System.out.println(" [x] Received '" + message + "'");
+      doWork(message);
       System.out.println(" [x] Done");
 
       channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false);