Improve restarting the consumer process to re-register when a Rabbit …

…MQ queue is deleted. (#1592)
dotnetcore · Oct 11, 2024 · 0c3142c · 0c3142c
1 parent d499a23
commit 0c3142c
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
@@ -285,6 +285,7 @@ private void WriteLog(LogMessageEventArgs logmsg)
         switch (logmsg.LogType)
         {
             case MqLogType.ConsumerCancelled:
+                _isHealthy = false;
                 _logger.LogWarning("RabbitMQ consumer cancelled. --> " + logmsg.Reason);
                 break;
             case MqLogType.ConsumerRegistered: