Skip to content

Commit b3cf972

Browse files
author
Matthias Radestock
committed
cosmetic
1 parent e3f1be2 commit b3cf972

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

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

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -105,7 +105,7 @@ public void configureSocket(Socket socket) throws IOException {
105105
super.configureSocket(socket);
106106
if(recvBufferSize > 0)
107107
socket.setReceiveBufferSize(recvBufferSize);
108-
if(sendBufferSize > 0 )
108+
if(sendBufferSize > 0)
109109
socket.setSendBufferSize(sendBufferSize);
110110
}
111111
}.newConnection(addresses, maxRedirects);
@@ -373,7 +373,7 @@ public void run() {
373373
int msgSeq = d.readInt();
374374
long msgNano = d.readLong();
375375
long nano = System.nanoTime();
376-
376+
377377
Envelope envelope = delivery.getEnvelope();
378378

379379
if (!autoAck) {
@@ -434,7 +434,7 @@ private void reset(long t) {
434434

435435
public synchronized void collectStats(long now, long latency) {
436436
msgCount++;
437-
437+
438438
if (latency > 0) {
439439
minLatency = Math.min(minLatency, latency);
440440
maxLatency = Math.max(maxLatency, latency);
@@ -455,9 +455,9 @@ public synchronized void collectStats(long now, long latency) {
455455
""));
456456
reset(now);
457457
}
458-
458+
459459
}
460-
460+
461461
}
462462

463463
}

0 commit comments

Comments
 (0)