Protect against no mset or mset.ackq

Signed-off-by: Derek Collison <derek@nats.io>
nats-io · Jun 27, 2024 · ffc90f8 · ffc90f8
1 parent acb2ee8
commit ffc90f8
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/server/consumer.go b/server/consumer.go
@@ -4322,7 +4322,7 @@ func (o *consumer) deliverMsg(dsubj, ackReply string, pmsg *jsPubMsg, dc uint64,
 
 	// If we are ack none and mset is interest only we should make sure stream removes interest.
 	if ap == AckNone && rp != LimitsPolicy {
-		if o.node == nil || o.cfg.Direct {
+		if mset != nil && mset.ackq != nil && (o.node == nil || o.cfg.Direct) {
 			mset.ackq.push(seq)
 		} else {
 			o.updateAcks(dseq, seq, _EMPTY_)