From 01404b3dc90d7e41e86b072497d492ca4fd02d52 Mon Sep 17 00:00:00 2001 From: Derek Collison Date: Wed, 10 Mar 2021 22:33:39 -0500 Subject: [PATCH] Protect against cluster and meta being gone Signed-off-by: Derek Collison --- server/jetstream_cluster.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/server/jetstream_cluster.go b/server/jetstream_cluster.go index 23797fe8..b8a06d91 100644 --- a/server/jetstream_cluster.go +++ b/server/jetstream_cluster.go @@ -2615,7 +2615,10 @@ func (js *jetStream) applyConsumerEntries(o *consumer, ce *CommittedEntry, isLea o.store.Update(state) } else if e.Type == EntryRemovePeer { js.mu.RLock() - ourID := js.cluster.meta.ID() + var ourID string + if js.cluster != nil && js.cluster.meta != nil { + ourID = js.cluster.meta.ID() + } js.mu.RUnlock() if peer := string(e.Data); peer == ourID { o.stopWithFlags(true, false, false)