diff options
Diffstat (limited to 'setup')
| -rw-r--r-- | setup/jetstream/nats.go | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/setup/jetstream/nats.go b/setup/jetstream/nats.go index 8820e86b..8630a141 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 |