Fix (admittedly insignificant) off-by-one error

Author: tonyg

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

@@ -236,14 +236,16 @@ public void run() {
             long now;
             now = startTime = lastStatsTime = System.currentTimeMillis();
             msgCount = 0;
-            int totalMsgCount = 1;
+            int totalMsgCount = 0;
 
             try {
 
-                for (; timeLimit == 0 || now < startTime + timeLimit;
-                     totalMsgCount++, msgCount++) {
+                while (timeLimit == 0 || now < startTime + timeLimit) {
                     delay(now);
                     publish(createMessage(totalMsgCount));
+		    totalMsgCount++;
+		    msgCount++;
+
                     if (txSize != 0 && totalMsgCount % txSize == 0) {
                         channel.txCommit();
                     }
@@ -340,21 +342,21 @@ public void run() {
             long now;
             long startTime;
             startTime = now = System.currentTimeMillis();
-            int totalMsgCount = 1;
+            int totalMsgCount = 0;
 
             Channel channel = q.getChannel();
 
             try {
 
-                for (; timeLimit == 0 || now < startTime + timeLimit;
-                     totalMsgCount++) {
+                while (timeLimit == 0 || now < startTime + timeLimit) {
                     Delivery delivery;
                     if (timeLimit == 0) {
                         delivery = q.nextDelivery();
                     } else {
                         delivery = q.nextDelivery(startTime + timeLimit - now);
                         if (delivery == null) break;
                     }
+		    totalMsgCount++;
 
                     DataInputStream d = new DataInputStream(new ByteArrayInputStream(delivery.getBody()));
                     int msgSeq = d.readInt();