change nats healtcheck

osstotalsoft · Oct 15, 2021 · 63bed9c · 63bed9c
1 parent 88a463c
commit 63bed9c
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/pkg/messaging/nats/nats.go b/pkg/messaging/nats/nats.go
@@ -336,12 +336,16 @@ func (n *natsStreamingPubSub) Close() error {
 }
 
 func (n *natsStreamingPubSub) IsHealthy() healthcheck.HealthResult {
-	if n.closed {
+	if n.closed ||
+		n.natStreamingConn == nil ||
+		n.natStreamingConn.NatsConn() == nil ||
+		n.natStreamingConn.NatsConn().Status() != nats.CONNECTED {
 		return healthcheck.HealthResult{
 			Status:      healthcheck.Unhealthy,
 			Description: "nats pubsub connection is closed",
 		}
 	}
+
 	return healthcheck.HealthyResult
 }