We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 987301f commit 74ad9fdCopy full SHA for 74ad9fd
js.go
@@ -59,7 +59,7 @@ type Auth struct {
59
func newJSClient(config *Config) (jetstream.JetStream, error) {
60
logger := config.Logger
61
opts := []nats.Option{
62
- nats.MaxReconnects(5),
+ nats.MaxReconnects(-1),
63
nats.DisconnectErrHandler(func(nc *nats.Conn, err error) {
64
if err != nil {
65
logger.Warn("disconnected from NATS", slog.String("error", err.Error()))
0 commit comments