do not error on missing a heartbeat

withinboredom · withinboredom · commit 837975a1abaf · 2025-07-30T19:56:05.000+02:00
Signed-off-by: Robert Landers &lt;landers.robert@gmail.com&gt;
diff --git a/cli/lib/consumer.go b/cli/lib/consumer.go
@@ -25,7 +25,7 @@ func BuildConsumer(stream jetstream.Stream, ctx context.Context, config *config.
 		panic(err)
 	}
 
-	iter, err := consumer.Messages(jetstream.PullMaxMessages(1))
+	iter, err := consumer.Messages(jetstream.PullMaxMessages(1), jetstream.WithMessagesErrOnMissingHeartbeat(false))
 	if err != nil {
 		panic(err)
 	}

Original file line number	Diff line number	Diff line change
`@@ -25,7 +25,7 @@ func BuildConsumer(stream jetstream.Stream, ctx context.Context, config *config.`
`25`	`25`	`panic(err)`
`26`	`26`	`}`
`27`	`27`
`28`		`- iter, err := consumer.Messages(jetstream.PullMaxMessages(1))`
	`28`	`+ iter, err := consumer.Messages(jetstream.PullMaxMessages(1), jetstream.WithMessagesErrOnMissingHeartbeat(false))`
`29`	`29`	`if err != nil {`
`30`	`30`	`panic(err)`
`31`	`31`	`}`