diff --git a/src/HouseofCat.RabbitMQ/Pools/ChannelHost.cs b/src/HouseofCat.RabbitMQ/Pools/ChannelHost.cs index 248ca57..e0eb350 100644 --- a/src/HouseofCat.RabbitMQ/Pools/ChannelHost.cs +++ b/src/HouseofCat.RabbitMQ/Pools/ChannelHost.cs @@ -146,7 +146,11 @@ public async Task BuildRabbitMQChannelAsync(int autoRecoveryDelay = 1000, protected virtual void ChannelClose(object sender, ShutdownEventArgs e) { - _logger.LogInformation(e.ReplyText); + if (e.ReplyCode == 200) + { _logger.LogDebug(e.ReplyText); } + else + { _logger.LogWarning(e.ReplyText); } + Closed = true; } diff --git a/src/HouseofCat.RabbitMQ/Pools/ConnectionHost.cs b/src/HouseofCat.RabbitMQ/Pools/ConnectionHost.cs index 1f9f0ce..50b2ed2 100644 --- a/src/HouseofCat.RabbitMQ/Pools/ConnectionHost.cs +++ b/src/HouseofCat.RabbitMQ/Pools/ConnectionHost.cs @@ -64,7 +64,7 @@ public void AssignConnection(IConnection connection) protected virtual void ConnectionClosed(object sender, ShutdownEventArgs e) { if (e.ReplyCode == 200) - { _logger.LogInformation(e.ReplyText); } + { _logger.LogDebug(e.ReplyText); } else { _logger.LogWarning(e.ReplyText); }