Browse Source

Ignore errors on RabbitMQ Nack message.

pull/7632/head
Halil İbrahim Kalkan 5 years ago
parent
commit
3ab79685b4
  1. 11
      framework/src/Volo.Abp.RabbitMQ/Volo/Abp/RabbitMQ/RabbitMqMessageConsumer.cs

11
framework/src/Volo.Abp.RabbitMQ/Volo/Abp/RabbitMQ/RabbitMqMessageConsumer.cs

@ -191,7 +191,16 @@ namespace Volo.Abp.RabbitMQ
}
catch (Exception ex)
{
Channel.BasicNack(basicDeliverEventArgs.DeliveryTag, multiple: false, requeue: true);
try
{
Channel.BasicNack(
basicDeliverEventArgs.DeliveryTag,
multiple: false,
requeue: true
);
}
catch { }
Logger.LogException(ex);
await ExceptionNotifier.NotifyAsync(ex);
}

Loading…
Cancel
Save