Skip to content

Commit d3c3302

Browse files
author
Matthew Sackman
committed
Should start the totalMsgCount at 1 on the consumer otherwise with *any* -n value we'll always commit after receiving the first message
1 parent 21f596c commit d3c3302

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -340,7 +340,7 @@ public void run() {
340340
long now;
341341
long startTime;
342342
startTime = now = System.currentTimeMillis();
343-
int totalMsgCount = 0;
343+
int totalMsgCount = 1;
344344

345345
Channel channel = q.getChannel();
346346

0 commit comments

Comments
 (0)