From ceb4a86d5787fcb186754f6d60fdc441bb06f6d0 Mon Sep 17 00:00:00 2001 From: Derek Collison Date: Fri, 7 May 2021 08:36:45 -0700 Subject: [PATCH] Check for nil chan Signed-off-by: Derek Collison --- server/consumer.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/server/consumer.go b/server/consumer.go index 3f954dff..ce285590 100644 --- a/server/consumer.go +++ b/server/consumer.go @@ -2202,7 +2202,7 @@ func (o *consumer) deliverMsg(dsubj, subj string, hdr, msg []byte, seq, dc uint6 o.outq.send(pmsg) // If we are ack none and mset is interest only we should make sure stream removes interest. - if ap == AckNone && mset.cfg.Retention != LimitsPolicy { + if ap == AckNone && mset.cfg.Retention != LimitsPolicy && mset.amch != nil { mset.amch <- seq }