From 25027b1e5dd83acd24ff7aa398a15357803062e7 Mon Sep 17 00:00:00 2001 From: Till Faelligen Date: Wed, 2 Feb 2022 09:32:20 +0100 Subject: [PATCH] Remove duplicate import --- setup/jetstream/nats.go | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/setup/jetstream/nats.go b/setup/jetstream/nats.go index d1408d391..b0647e7af 100644 --- a/setup/jetstream/nats.go +++ b/setup/jetstream/nats.go @@ -9,7 +9,6 @@ import ( "github.com/sirupsen/logrus" natsserver "github.com/nats-io/nats-server/v2/server" - "github.com/nats-io/nats.go" natsclient "github.com/nats-io/nats.go" ) @@ -60,7 +59,7 @@ func Prepare(cfg *config.JetStream) natsclient.JetStreamContext { func setupNATS(cfg *config.JetStream, nc *natsclient.Conn) natsclient.JetStreamContext { if nc == nil { var err error - nc, err = nats.Connect(strings.Join(cfg.Addresses, ",")) + nc, err = natsclient.Connect(strings.Join(cfg.Addresses, ",")) if err != nil { logrus.WithError(err).Panic("Unable to connect to NATS") return nil @@ -85,7 +84,7 @@ func setupNATS(cfg *config.JetStream, nc *natsclient.Conn) natsclient.JetStreamC // If we're trying to keep everything in memory (e.g. unit tests) // then overwrite the storage policy. if cfg.InMemory { - stream.Storage = nats.MemoryStorage + stream.Storage = natsclient.MemoryStorage } // Namespace the streams without modifying the original streams