From 4d636428c04f9661dd84af1293044441c934ed36 Mon Sep 17 00:00:00 2001
From: Neil Alexander <neilalexander@users.noreply.github.com>
Date: Tue, 22 Mar 2022 14:22:06 +0000
Subject: [PATCH] Check streams too

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

diff --git a/setup/jetstream/nats.go b/setup/jetstream/nats.go
index 3e373530a..64cfccff3 100644
--- a/setup/jetstream/nats.go
+++ b/setup/jetstream/nats.go
@@ -1,6 +1,7 @@
 package jetstream
 
 import (
+	"reflect"
 	"strings"
 	"sync"
 	"time"
@@ -82,6 +83,8 @@ func setupNATS(cfg *config.JetStream, nc *natsclient.Conn) (natsclient.JetStream
 		}
 		if info != nil {
 			switch {
+			case !reflect.DeepEqual(info.Config.Subjects, stream.Subjects):
+				fallthrough
 			case info.Config.Retention != stream.Retention:
 				fallthrough
 			case info.Config.Storage != stream.Storage: