fix: Return if mq client is nil (#744)

bitcoin-sv · Jan 13, 2025 · 4cedcc5 · 4cedcc5
1 parent 65770e3
commit 4cedcc5
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/internal/message_queue/nats/client/nats_jetstream/nats_jetstream_client.go b/internal/message_queue/nats/client/nats_jetstream/nats_jetstream_client.go
@@ -307,6 +307,10 @@ func (cl *Client) Subscribe(topic string, msgFunc func([]byte) error) error {
 }
 
 func (cl *Client) Shutdown() {
+	if cl == nil {
+		return
+	}
+
 	if cl.removableStreamConsumerMapping != nil {
 		for stream, consumer := range cl.removableStreamConsumerMapping {
 			err := cl.js.DeleteConsumer(context.Background(), stream, consumer)