From bf68068fa6622e07c2e7ef560659969f8b8f963b Mon Sep 17 00:00:00 2001 From: "R.I.Pienaar" Date: Fri, 30 Oct 2020 15:06:22 +0100 Subject: [PATCH] address review Signed-off-by: R.I.Pienaar --- server/consumer.go | 4 ++-- test/jetstream_test.go | 3 +-- 2 files changed, 3 insertions(+), 4 deletions(-) diff --git a/server/consumer.go b/server/consumer.go index 3cdf62f2..681b65e0 100644 --- a/server/consumer.go +++ b/server/consumer.go @@ -1076,8 +1076,8 @@ func nextReqFromMsg(msg []byte) (time.Time, int, bool, error) { bs := 1 // Naked batch size here for backward compatibility. switch { - case bytes.HasPrefix(msg, AckNext): - if n, _ := fmt.Sscanf(string(msg), ackNextCnt, &bs); n == 0 { + case strings.HasPrefix(req, string(AckNext)): + if n, _ := fmt.Sscanf(req, ackNextCnt, &bs); n == 0 { bs = 1 } default: diff --git a/test/jetstream_test.go b/test/jetstream_test.go index 14e987a5..f57fcdf2 100644 --- a/test/jetstream_test.go +++ b/test/jetstream_test.go @@ -83,7 +83,6 @@ func RunBasicJetStreamServer() *server.Server { opts := DefaultTestOptions opts.Port = -1 opts.JetStream = true - opts.NoLog = true return RunServer(&opts) } @@ -3018,7 +3017,7 @@ func TestJetStreamConsumerAckAck(t *testing.T) { testAck(server.AckTerm) } -func TestJetStreamNack(t *testing.T) { +func TestJetStreamAckNext(t *testing.T) { s := RunBasicJetStreamServer() defer s.Shutdown()