Merge pull request #1252 from ripienaar/csv

Correctly handle stdin for consumers check
nats-io · Jan 24, 2025 · 80bbf99 · 80bbf99
2 parents a5f69d5 + c19f2db
commit 80bbf99
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/cli/server_consumer_check.go b/cli/server_consumer_check.go
@@ -83,7 +83,7 @@ func (c *ConsumerCheckCmd) consumerCheck(_ *fisk.ParseContext) error {
 	var err error
 	var nc *nats.Conn
 
-	if !c.csv {
+	if !c.stdin {
 		nc, _, err = prepareHelper(opts().Servers, natsOpts()...)
 		if err != nil {
 			return err
@@ -93,7 +93,7 @@ func (c *ConsumerCheckCmd) consumerCheck(_ *fisk.ParseContext) error {
 
 	sys := sysclient.New(nc)
 
-	if !c.csv {
+	if !c.stdin {
 		if c.expected == 0 {
 			c.expected, err = currentActiveServers(nc)
 			if err != nil {