From d66cc04f048ad8e62e0fd4e6b3c9fd54f523f3fb Mon Sep 17 00:00:00 2001
From: jar3b <hellotan@live.ru>
Date: Wed, 13 Oct 2021 14:05:47 +0300
Subject: [PATCH] fix: stream name in AddOrUpdateStream()

---
 jetstream.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/jetstream.go b/jetstream.go
index bb267f2..03c15e8 100644
--- a/jetstream.go
+++ b/jetstream.go
@@ -30,7 +30,7 @@ func FinalizeJetStream(subscriptions *[]*nats.Subscription) error {
 }
 
 func AddOrUpdateStream(cfg *nats.StreamConfig, opts ...nats.JSOpt) (*nats.StreamInfo, error) {
-	_, err := JsClient.StreamInfo("metric-stream")
+	_, err := JsClient.StreamInfo(cfg.Name)
 	if err != nil && err.Error() != "nats: stream not found" {
 		return nil, err
 	}