cosmetic

Author: Matthias Radestock

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

@@ -109,7 +109,7 @@ public static void main(String[] args) {
                 if (prefetchCount > 0) channel.basicQos(prefetchCount);
                 channel.basicConsume(queueName, autoAck, consumer);
                 channel.queueBind(queueName, exchangeName, id);
-                Thread t = 
+                Thread t =
                     new Thread(new Consumer(consumer, id,
                                             consumerTxSize, autoAck,
                                             stats, timeLimit));
@@ -125,7 +125,7 @@ public static void main(String[] args) {
                 Channel channel = conn.createChannel();
                 if (producerTxSize > 0) channel.txSelect();
                 channel.exchangeDeclare(exchangeName, exchangeType);
-                Thread t = 
+                Thread t =
                     new Thread(new Producer(channel, exchangeName, id,
                                             flags, producerTxSize,
                                             1000L * samplingInterval,
@@ -361,7 +361,7 @@ public void run() {
                     int msgSeq = d.readInt();
                     long msgNano = d.readLong();
                     long nano = System.nanoTime();
-                    
+
                     Envelope envelope = delivery.getEnvelope();
 
                     if (!autoAck) {
@@ -422,7 +422,7 @@ private void reset(long t) {
 
         public synchronized void collectStats(long now, long latency) {
             msgCount++;
-            
+
             if (latency > 0) {
                 minLatency = Math.min(minLatency, latency);
                 maxLatency = Math.max(maxLatency, latency);
@@ -437,15 +437,15 @@ public synchronized void collectStats(long now, long latency) {
                                    " msg/s" +
                                    (latencyCount > 0 ?
                                     ", min/avg/max latency: " +
-                                    minLatency/1000L + "/" + 
+                                    minLatency/1000L + "/" +
                                     cumulativeLatency / (1000L * latencyCount) + "/" +
                                     maxLatency/1000L + " microseconds" :
                                     ""));
                 reset(now);
             }
-            
+
         }
-        
+
     }
 
 }