Update RabbitMqMessageConsumer.cs

4 years ago · 282d9ada01
1 changed files with 0 additions and 8 deletions
--- a/framework/src/Volo.Abp.RabbitMQ/Volo/Abp/RabbitMQ/RabbitMqMessageConsumer.cs
+++ b/framework/src/Volo.Abp.RabbitMQ/Volo/Abp/RabbitMQ/RabbitMqMessageConsumer.cs
@ -176,14 +176,6 @@ public class RabbitMqMessageConsumer : IRabbitMqMessageConsumer, ITransientDepen
        }
        catch (Exception ex)
        {
-            if (ex is OperationInterruptedException operationInterruptedException &&
-                operationInterruptedException.ShutdownReason.ReplyCode == 406 &&
-                operationInterruptedException.Message.Contains("arg 'x-dead-letter-exchange'"))
-            {
-                Logger.LogException(ex, LogLevel.Warning);
-                await ExceptionNotifier.NotifyAsync(ex, logLevel: LogLevel.Warning);
-            }
-
            Logger.LogException(ex, LogLevel.Warning);
            await ExceptionNotifier.NotifyAsync(ex, logLevel: LogLevel.Warning);
        }