From 4cedcc51fe4ef03bdd1f727359bec75c689ba911 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Michael=20B=C3=B6ckli?=
 <42514703+boecklim@users.noreply.github.com>
Date: Mon, 13 Jan 2025 11:37:01 +0100
Subject: [PATCH] fix: Return if mq client is nil (#744)

---
 .../nats/client/nats_jetstream/nats_jetstream_client.go       | 4 ++++
 1 file changed, 4 insertions(+)

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
index 60559b75a..d893af025 100644
--- 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)