diff --git a/framework/src/Volo.Abp.RabbitMQ/Volo/Abp/RabbitMQ/RabbitMqMessageConsumer.cs b/framework/src/Volo.Abp.RabbitMQ/Volo/Abp/RabbitMQ/RabbitMqMessageConsumer.cs index b94663d886..0c180a4ac7 100644 --- a/framework/src/Volo.Abp.RabbitMQ/Volo/Abp/RabbitMQ/RabbitMqMessageConsumer.cs +++ b/framework/src/Volo.Abp.RabbitMQ/Volo/Abp/RabbitMQ/RabbitMqMessageConsumer.cs @@ -191,6 +191,7 @@ namespace Volo.Abp.RabbitMQ } catch (Exception ex) { + Channel.BasicNack(basicDeliverEventArgs.DeliveryTag, multiple: false, requeue: true); Logger.LogException(ex); await ExceptionNotifier.NotifyAsync(ex); }