Fixed the health check could not get the status correctly when Rabbit…

…MQ lost connection and quickly recovered. #1140
dotnetcore · Jun 8, 2022 · 7a7a1bd · 7a7a1bd
1 parent 432500f
commit 7a7a1bd
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/DotNetCore.CAP/Internal/IConsumerRegister.Default.cs b/src/DotNetCore.CAP/Internal/IConsumerRegister.Default.cs
@@ -292,6 +292,7 @@ private void WriteLog(object sender, LogMessageEventArgs logmsg)
  _logger.LogWarning("RabbitMQ consumer cancelled. --> " + logmsg.Reason);
  break;
  case MqLogType.ConsumerRegistered:
+ _isHealthy = true;
  _logger.LogInformation("RabbitMQ consumer registered. --> " + logmsg.Reason);
  break;
  case MqLogType.ConsumerUnregistered: