From 1364d85985c752088c9b5b86003bf4c837bd25d5 Mon Sep 17 00:00:00 2001
From: Neil Alexander <neilalexander@users.noreply.github.com>
Date: Tue, 22 Mar 2022 14:52:52 +0000
Subject: [PATCH] Reconstruct properly

---
 setup/jetstream/nats.go | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/setup/jetstream/nats.go b/setup/jetstream/nats.go
index 04b24c1b2..6c62fa057 100644
--- a/setup/jetstream/nats.go
+++ b/setup/jetstream/nats.go
@@ -92,10 +92,12 @@ func setupNATS(cfg *config.JetStream, nc *natsclient.Conn) (natsclient.JetStream
 				fallthrough
 			case info.Config.Storage != stream.Storage:
 				if err = s.DeleteStream(name); err != nil {
-					logrus.WithError(err).Fatal("Unable to recreate stream")
+					logrus.WithError(err).Fatal("Unable to delete stream")
 				}
+				info = nil
 			}
-		} else {
+		}
+		if info == nil {
 			// If we're trying to keep everything in memory (e.g. unit tests)
 			// then overwrite the storage policy.
 			if cfg.InMemory {