Improve

framework/src/Volo.Abp.BackgroundJobs.RabbitMQ/Volo/Abp/BackgroundJobs/RabbitMQ/JobQueue.cs

@@ -141,14 +141,14 @@ public class JobQueue<TArgs> : IJobQueue<TArgs>
 
         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,

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,