Tutorial two for java.

Author: Ann

java/NewTask.java

@@ -0,0 +1,34 @@
+import com.rabbitmq.client.ConnectionFactory;
+import com.rabbitmq.client.Connection;
+import com.rabbitmq.client.Channel;
+import com.rabbitmq.client.MessageProperties;
+
+public class NewTask {
+  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();
+
+     // make durable
+    chan.queueDeclare("task_queue", true, false, false, null);
+
+    String message = joinStrings(argv);
+    if (message == "") message = "Hello World!";
+
+     // make persistent
+    chan.basicPublish("", "task_queue", MessageProperties.PERSISTENT_TEXT_PLAIN, message.getBytes());
+    System.out.println(" [x] Sent '" + message + "'");
+    chan.close();
+    conn.close();
+  }
+  
+  private static String joinStrings(String[] strings){
+     String words = "";
+     for (String astring: strings)
+    	words = words + astring + " ";
+     return words.trim();
+  }
+}

java/Worker.java

@@ -0,0 +1,44 @@
+import com.rabbitmq.client.ConnectionFactory;
+import com.rabbitmq.client.Connection;
+import com.rabbitmq.client.Channel;
+import com.rabbitmq.client.QueueingConsumer;
+
+public class Worker {
+    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();
+
+    // make durable
+    chan.queueDeclare("task_queue", true, false, false, null);
+    System.out.println(" [*] Waiting for messages. To exit press CTRL+C");
+
+    // prefetch 1
+    chan.basicQos(1);
+    QueueingConsumer consumer = new QueueingConsumer(chan);
+    chan.basicConsume("task_queue", false, consumer);
+
+    while (true) {
+      QueueingConsumer.Delivery delivery = consumer.nextDelivery();
+      String body = new String(delivery.getBody());
+      System.out.println(" [x] Received " + body);
+      Thread.sleep(doDots(body));	// simulate action
+      System.out.println(" [x] Done");
+      // acknowledge
+      chan.basicAck(delivery.getEnvelope().getDeliveryTag(), false);
+    }
+  }
+
+
+  private static int doDots(String body){ 
+// just do something to get a number for simulation
+	int x = body.indexOf('.') ;
+	if (x < 0) return 0;
+                body = body.substring(x); 
+	return body.length() ;
+  }
+}