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 b3653b5e81..3d7e8c05ff 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
@@ -21,7 +21,7 @@ namespace Volo.Abp.BackgroundJobs.RabbitMQ
         protected BackgroundJobConfiguration JobConfiguration { get; }
         protected JobQueueConfiguration QueueConfiguration { get; }
         protected IChannelAccessor ChannelAccessor { get; private set; }
-        protected EventingBasicConsumer Consumer { get; private set; }
+        protected AsyncEventingBasicConsumer Consumer { get; private set; }
 
         public ILogger<JobQueue<TArgs>> Logger { get; set; }
 
@@ -135,7 +135,7 @@ namespace Volo.Abp.BackgroundJobs.RabbitMQ
 
             if (AbpBackgroundJobOptions.IsJobExecutionEnabled)
             {
-                var Consumer = new AsyncEventingBasicConsumer(ChannelAccessor.Channel);
+                Consumer = new AsyncEventingBasicConsumer(ChannelAccessor.Channel);
                 Consumer.Received += MessageReceived;
 
                 //TODO: What BasicConsume returns?