From 3e1445176ab9cb79f4a2fed63b03784c729b6d73 Mon Sep 17 00:00:00 2001
From: Till Faelligen <2353100+S7evinK@users.noreply.github.com>
Date: Fri, 22 Mar 2024 21:39:26 +0100
Subject: [PATCH] Reuse existing NATS connection

---
 setup/jetstream/nats.go | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/setup/jetstream/nats.go b/setup/jetstream/nats.go
index 8820e86b2..8630a1411 100644
--- a/setup/jetstream/nats.go
+++ b/setup/jetstream/nats.go
@@ -38,7 +38,12 @@ func (s *NATSInstance) Prepare(process *process.ProcessContext, cfg *config.JetS
 	defer natsLock.Unlock()
 	// check if we need an in-process NATS Server
 	if len(cfg.Addresses) != 0 {
-		return setupNATS(process, cfg, nil)
+		// reuse existing connections
+		if s.nc != nil {
+			return s.js, s.nc
+		}
+		s.js, s.nc = setupNATS(process, cfg, nil)
+		return s.js, s.nc
 	}
 	if s.Server == nil {
 		var err error