From 2f232537f63aa236f7c94411b4b92fe617ecbda0 Mon Sep 17 00:00:00 2001
From: Neil Alexander <neilalexander@users.noreply.github.com>
Date: Tue, 22 Mar 2022 14:41:48 +0000
Subject: [PATCH] Recreate if subjects wrong

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

diff --git a/setup/jetstream/nats.go b/setup/jetstream/nats.go
index 64cfccff3..04b24c1b2 100644
--- a/setup/jetstream/nats.go
+++ b/setup/jetstream/nats.go
@@ -81,6 +81,9 @@ func setupNATS(cfg *config.JetStream, nc *natsclient.Conn) (natsclient.JetStream
 		if err != nil && err != natsclient.ErrStreamNotFound {
 			logrus.WithError(err).Fatal("Unable to get stream info")
 		}
+		if len(stream.Subjects) == 0 {
+			stream.Subjects = []string{name, name + ".>"}
+		}
 		if info != nil {
 			switch {
 			case !reflect.DeepEqual(info.Config.Subjects, stream.Subjects):
@@ -93,10 +96,6 @@ func setupNATS(cfg *config.JetStream, nc *natsclient.Conn) (natsclient.JetStream
 				}
 			}
 		} else {
-			if len(stream.Subjects) == 0 {
-				stream.Subjects = []string{name}
-			}
-
 			// If we're trying to keep everything in memory (e.g. unit tests)
 			// then overwrite the storage policy.
 			if cfg.InMemory {