cosmetics and minor refactoring

eliminate some helper methods
better naming

Author: rade

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

@@ -242,7 +242,7 @@ public static class Producer implements Runnable, ReturnListener, AckListener {
         private long    startTime;
         private long    lastStatsTime;
         private int     msgCount;
-        private int     basicReturnCount;
+        private int     returnCount;
 
         private boolean confirm;
         private long    confirmMax;
@@ -270,33 +270,25 @@ public Producer(Channel channel, String exchangeName, String id,
             this.confirm      = confirm;
         }
 
-        public void handleBasicReturn(int replyCode,
-                                      String replyText,
-                                      String exchange,
-                                      String routingKey,
-                                      AMQP.BasicProperties properties,
-                                      byte[] body) throws IOException {
-            logBasicReturn();
-        }
-
-        public synchronized void logBasicReturn() {
-            basicReturnCount++;
-        }
-
-        public synchronized void resetBasicReturns() {
-            basicReturnCount = 0;
-        }
-
-        public void handleAck(long sequenceNumber, boolean multiple) {
-            logAck(sequenceNumber);
+        public synchronized void handleBasicReturn(int replyCode,
+                                                   String replyText,
+                                                   String exchange,
+                                                   String routingKey,
+                                                   AMQP.BasicProperties properties,
+                                                   byte[] body)
+            throws IOException {
+            returnCount++;
         }
 
-        private synchronized void resetConfirms() {
+        public synchronized void resetCounts() {
+            msgCount = 0;
+            returnCount = 0;
             confirmCount = 0;
         }
 
-        private synchronized void logAck(long seqNum) {
-            mostRecentConfirmed = seqNum;
+        public synchronized void handleAck(long sequenceNumber,
+                                           boolean multiple) {
+            mostRecentConfirmed = sequenceNumber;
             confirmCount++;
         }
 
@@ -368,8 +360,8 @@ private void delay(long now)
                                  (msgCount * 1000L / elapsed) +
                                  " msg/s");
                 if (mandatory || immediate) {
-                    System.out.print(", basic returns: " +
-                                     (basicReturnCount * 1000L / elapsed) +
+                    System.out.print(", returns: " +
+                                     (returnCount * 1000L / elapsed) +
                                      " ret/s");
                 }
                 if (confirm) {
@@ -378,9 +370,7 @@ private void delay(long now)
                                      " c/s");
                 }
                 System.out.println();
-                resetBasicReturns();
-                resetConfirms();
-                msgCount = 0;
+                resetCounts();
                 lastStatsTime = now;
             }
         }