Skip to content

Commit

Permalink
Update to the new version of nats.go that merged in the consumer Stop…
Browse files Browse the repository at this point in the history
…After()
  • Loading branch information
jnmoyne committed Nov 2, 2023
1 parent 02b2035 commit 4ac068f
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion cli/bench_command.go
Original file line number Diff line number Diff line change
Expand Up @@ -1028,7 +1028,7 @@ func (c *benchCmd) runSubscriber(bm *bench.Benchmark, nc *nats.Conn, startwg *sy
}
}
if c.push {
cc, err := consumer.Consume(mh2, jetstream.PullMaxMessages(c.consumerBatch), jetstream.AutoStopAfter(numMsg))
cc, err := consumer.Consume(mh2, jetstream.PullMaxMessages(c.consumerBatch), jetstream.StopAfter(numMsg))
if err != nil {
return
}
Expand Down

0 comments on commit 4ac068f

Please sign in to comment.