From c89883b6aaf0b57b9915d6d31ff61cdfc44af03d Mon Sep 17 00:00:00 2001 From: Tomasz Pietrek Date: Tue, 24 Jan 2023 11:25:37 +0100 Subject: [PATCH] Fix assigning signal subscription to consumer Signed-off-by: Tomasz Pietrek --- server/consumer.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/server/consumer.go b/server/consumer.go index aceaf590..b5d5adc2 100644 --- a/server/consumer.go +++ b/server/consumer.go @@ -4347,7 +4347,9 @@ func (o *consumer) signalSub() *subscription { if subject == _EMPTY_ { subject = fwcs } - return &subscription{subject: []byte(subject), icb: o.processStreamSignal} + sub := &subscription{subject: []byte(subject), icb: o.processStreamSignal} + o.sigSub = sub + return sub } // This is what will be called when our parent stream wants to kick us regarding a new message.