From 0df01129f0a7ec0d4dd960d91049bbdaca81c279 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Halil=20=C4=B0brahim=20Kalkan?= <hi_kalkan@yahoo.com>
Date: Fri, 8 Jan 2021 18:10:08 +0300
Subject: [PATCH] Fixed #7104: Setting RabbitMQ connection in appsettings.json
 causes consumers to not consume messages

---
 .../Volo/Abp/RabbitMQ/AbpRabbitMqModule.cs                 | 7 +++++++
 .../Volo/Abp/RabbitMQ/RabbitMqConnections.cs               | 2 +-
 2 files changed, 8 insertions(+), 1 deletion(-)

diff --git a/framework/src/Volo.Abp.RabbitMQ/Volo/Abp/RabbitMQ/AbpRabbitMqModule.cs b/framework/src/Volo.Abp.RabbitMQ/Volo/Abp/RabbitMQ/AbpRabbitMqModule.cs
index a96309a1a8..feeb3a0431 100644
--- a/framework/src/Volo.Abp.RabbitMQ/Volo/Abp/RabbitMQ/AbpRabbitMqModule.cs
+++ b/framework/src/Volo.Abp.RabbitMQ/Volo/Abp/RabbitMQ/AbpRabbitMqModule.cs
@@ -15,6 +15,13 @@ namespace Volo.Abp.RabbitMQ
         {
             var configuration = context.Services.GetConfiguration();
             Configure<AbpRabbitMqOptions>(configuration.GetSection("RabbitMQ"));
+            Configure<AbpRabbitMqOptions>(options =>
+            {
+                foreach (var connectionFactory in options.Connections.Values)
+                {
+                    connectionFactory.DispatchConsumersAsync = true;
+                }
+            });
         }
 
         public override void OnApplicationShutdown(ApplicationShutdownContext context)
diff --git a/framework/src/Volo.Abp.RabbitMQ/Volo/Abp/RabbitMQ/RabbitMqConnections.cs b/framework/src/Volo.Abp.RabbitMQ/Volo/Abp/RabbitMQ/RabbitMqConnections.cs
index f2b5168d82..a725291df8 100644
--- a/framework/src/Volo.Abp.RabbitMQ/Volo/Abp/RabbitMQ/RabbitMqConnections.cs
+++ b/framework/src/Volo.Abp.RabbitMQ/Volo/Abp/RabbitMQ/RabbitMqConnections.cs
@@ -19,7 +19,7 @@ namespace Volo.Abp.RabbitMQ
 
         public RabbitMqConnections()
         {
-            Default = new ConnectionFactory() { DispatchConsumersAsync = true };
+            Default = new ConnectionFactory();
         }
 
         public ConnectionFactory GetOrDefault(string connectionName)