change Nats Health policy

osstotalsoft · Mar 22, 2022 · 401e8da · 401e8da
1 parent 8195127
commit 401e8da
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/pkg/messaging/nats/nats.go b/pkg/messaging/nats/nats.go
@@ -365,7 +365,8 @@ func (n *natsStreamingPubSub) IsHealthy(ctx context.Context) healthcheck.HealthR
 	if n.closed ||
 		n.natStreamingConn == nil ||
 		n.natStreamingConn.NatsConn() == nil ||
-		n.natStreamingConn.NatsConn().Status() != nats.CONNECTED {
+		n.natStreamingConn.NatsConn().Status() == nats.CLOSED ||
+		n.natStreamingConn.NatsConn().Status() == nats.DISCONNECTED {
 		return healthcheck.HealthResult{
 			Status:      healthcheck.Unhealthy,
 			Description: "nats pubsub connection is closed",