@@ -109,7 +109,7 @@ public static void main(String[] args) {
109
109
if (prefetchCount > 0 ) channel .basicQos (prefetchCount );
110
110
channel .basicConsume (queueName , autoAck , consumer );
111
111
channel .queueBind (queueName , exchangeName , id );
112
- Thread t =
112
+ Thread t =
113
113
new Thread (new Consumer (consumer , id ,
114
114
consumerTxSize , autoAck ,
115
115
stats , timeLimit ));
@@ -125,7 +125,7 @@ public static void main(String[] args) {
125
125
Channel channel = conn .createChannel ();
126
126
if (producerTxSize > 0 ) channel .txSelect ();
127
127
channel .exchangeDeclare (exchangeName , exchangeType );
128
- Thread t =
128
+ Thread t =
129
129
new Thread (new Producer (channel , exchangeName , id ,
130
130
flags , producerTxSize ,
131
131
1000L * samplingInterval ,
@@ -361,7 +361,7 @@ public void run() {
361
361
int msgSeq = d .readInt ();
362
362
long msgNano = d .readLong ();
363
363
long nano = System .nanoTime ();
364
-
364
+
365
365
Envelope envelope = delivery .getEnvelope ();
366
366
367
367
if (!autoAck ) {
@@ -422,7 +422,7 @@ private void reset(long t) {
422
422
423
423
public synchronized void collectStats (long now , long latency ) {
424
424
msgCount ++;
425
-
425
+
426
426
if (latency > 0 ) {
427
427
minLatency = Math .min (minLatency , latency );
428
428
maxLatency = Math .max (maxLatency , latency );
@@ -437,15 +437,15 @@ public synchronized void collectStats(long now, long latency) {
437
437
" msg/s" +
438
438
(latencyCount > 0 ?
439
439
", min/avg/max latency: " +
440
- minLatency /1000L + "/" +
440
+ minLatency /1000L + "/" +
441
441
cumulativeLatency / (1000L * latencyCount ) + "/" +
442
442
maxLatency /1000L + " microseconds" :
443
443
"" ));
444
444
reset (now );
445
445
}
446
-
446
+
447
447
}
448
-
448
+
449
449
}
450
450
451
451
}
0 commit comments