comments

Author: Alexandru Scvortov

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

@@ -55,7 +55,9 @@ public static void main(String[] args)
     {
         connectionFactory = new ConnectionFactory();
 
+        // Publish MSG_COUNT messages and wait for confirms.
         (new Thread(new Consumer())).start();
+        // Consume MSG_COUNT messages.
         (new Thread(new Publisher())).start();
     }
 
@@ -66,6 +68,7 @@ public void run() {
             try {
                 long startTime = System.currentTimeMillis();
 
+                // Setup
                 Connection conn = connectionFactory.newConnection();
                 Channel ch = conn.createChannel();
                 ch.queueDeclare(QUEUE_NAME, true, false, true, null);
@@ -82,16 +85,19 @@ public void handleAck(long seqNo,
                         }
                     });
 
+                // Publish
                 for (long i = 0; i < MSG_COUNT; ++i) {
                     ackSet.add(i);
                     ch.basicPublish("", QUEUE_NAME,
                                     MessageProperties.PERSISTENT_BASIC,
                                     "nop".getBytes());
                 }
 
+                // Wait
                 while (ackSet.size() > 0)
                     Thread.sleep(10);
 
+                // Cleanup
                 ch.close();
                 conn.close();
 
@@ -107,14 +113,19 @@ public void handleAck(long seqNo,
     static class Consumer implements Runnable {
         public void run() {
             try {
+                // Setup
                 Connection conn = connectionFactory.newConnection();
                 Channel ch = conn.createChannel();
                 ch.queueDeclare(QUEUE_NAME, true, false, true, null);
+
+                // Consume
                 QueueingConsumer qc = new QueueingConsumer(ch);
                 ch.basicConsume(QUEUE_NAME, true, qc);
                 for (int i = 0; i < MSG_COUNT; ++i) {
                     qc.nextDelivery();
                 }
+
+                // Consume
                 ch.close();
                 conn.close();
             } catch (Throwable e) {