diff --git a/internal/event/target/nats.go b/internal/event/target/nats.go index 684ad110d..441b1d0b8 100644 --- a/internal/event/target/nats.go +++ b/internal/event/target/nats.go @@ -256,10 +256,12 @@ func (target *NATSTarget) IsActive() (bool, error) { if target.natsConn != nil && target.args.JetStream.Enable { target.jstream, connErr = target.natsConn.JetStream() - if connErr.Error() == nats.ErrNoServers.Error() { - return false, errNotConnected + if connErr != nil { + if connErr.Error() == nats.ErrNoServers.Error() { + return false, errNotConnected + } + return false, connErr } - return false, connErr } return true, nil