adds name to nats connection (#148)

synadia-io · Mar 26, 2024 · c5fc403 · c5fc403
1 parent 77ae1d4
commit c5fc403
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/internal/models/cli.go b/internal/models/cli.go
@@ -181,7 +181,14 @@ func GenerateConnectionFromOpts(opts *Options) (*nats.Conn, error) {
 		return nil, err
 	}
 
-	conn, err := opts.Configuration.Connect()
+	conn, err := opts.Configuration.Connect(nats.Name(
+		func() string {
+			if opts.ConnectionName == "" {
+				return "nex"
+			}
+			return opts.ConnectionName
+		}(),
+	))
 	if err != nil {
 		return nil, err
 	}