Skip to content

Commit

Permalink
Total msg count is 3m not 1m
Browse files Browse the repository at this point in the history
Signed-off-by: Byron Ruth <byron@nats.io>
  • Loading branch information
bruth committed Mar 30, 2024
1 parent 4b55db7 commit 0681899
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions server/consumer_test.go
Expand Up @@ -64,7 +64,7 @@ func TestJetStreamWorkQueueMultiConsumer(t *testing.T) {
}
}
}
t.Logf("Published %d messages", cnt)
t.Logf("Published %d messages", cnt*3)
}()

wg := &sync.WaitGroup{}
Expand Down Expand Up @@ -96,7 +96,7 @@ func TestJetStreamWorkQueueMultiConsumer(t *testing.T) {

// Keep track of the last message counter which is determined
// based on the third token in the subject.
rem := 1_000_000
rem := 3_000_000
lstCnt := 0
for rem > 0 {
// Randomly drain the consumer and rebind the consumer every so often.
Expand Down

0 comments on commit 0681899

Please sign in to comment.