From f4dee528fb4a761b8dfc7df14d4f1a0dfea9cb7c Mon Sep 17 00:00:00 2001 From: liangshiwei Date: Mon, 25 Jul 2022 17:01:12 +0800 Subject: [PATCH] Improve --- .../Volo/Abp/BackgroundJobs/RabbitMQ/JobQueue.cs | 6 +++--- .../Volo/Abp/RabbitMQ/RabbitMqMessageConsumer.cs | 8 ++++---- 2 files changed, 7 insertions(+), 7 deletions(-) diff --git a/framework/src/Volo.Abp.BackgroundJobs.RabbitMQ/Volo/Abp/BackgroundJobs/RabbitMQ/JobQueue.cs b/framework/src/Volo.Abp.BackgroundJobs.RabbitMQ/Volo/Abp/BackgroundJobs/RabbitMQ/JobQueue.cs index 59481840aa..9c3bf26e62 100644 --- a/framework/src/Volo.Abp.BackgroundJobs.RabbitMQ/Volo/Abp/BackgroundJobs/RabbitMQ/JobQueue.cs +++ b/framework/src/Volo.Abp.BackgroundJobs.RabbitMQ/Volo/Abp/BackgroundJobs/RabbitMQ/JobQueue.cs @@ -141,14 +141,14 @@ public class JobQueue : IJobQueue if (AbpBackgroundJobOptions.IsJobExecutionEnabled) { - Consumer = new AsyncEventingBasicConsumer(ChannelAccessor.Channel); - Consumer.Received += MessageReceived; - if (QueueConfiguration.PrefetchCount.HasValue) { ChannelAccessor.Channel.BasicQos(0, QueueConfiguration.PrefetchCount.Value, false); } + Consumer = new AsyncEventingBasicConsumer(ChannelAccessor.Channel); + Consumer.Received += MessageReceived; + //TODO: What BasicConsume returns? ChannelAccessor.Channel.BasicConsume( queue: QueueConfiguration.QueueName, 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 c6a61b5da2..5c45b6aefc 100644 --- a/framework/src/Volo.Abp.RabbitMQ/Volo/Abp/RabbitMQ/RabbitMqMessageConsumer.cs +++ b/framework/src/Volo.Abp.RabbitMQ/Volo/Abp/RabbitMQ/RabbitMqMessageConsumer.cs @@ -165,14 +165,14 @@ public class RabbitMqMessageConsumer : IRabbitMqMessageConsumer, ITransientDepen arguments: Queue.Arguments ); - var consumer = new AsyncEventingBasicConsumer(Channel); - consumer.Received += HandleIncomingMessageAsync; - if (Queue.PrefetchCount.HasValue) { Channel.BasicQos(0, Queue.PrefetchCount.Value, false); } - + + var consumer = new AsyncEventingBasicConsumer(Channel); + consumer.Received += HandleIncomingMessageAsync; + Channel.BasicConsume( queue: Queue.QueueName, autoAck: false,