Browse Source

Fixed #7104: Setting RabbitMQ connection in appsettings.json causes consumers to not consume messages

pull/7114/head
Halil İbrahim Kalkan 5 years ago
parent
commit
0df01129f0
  1. 7
      framework/src/Volo.Abp.RabbitMQ/Volo/Abp/RabbitMQ/AbpRabbitMqModule.cs
  2. 2
      framework/src/Volo.Abp.RabbitMQ/Volo/Abp/RabbitMQ/RabbitMqConnections.cs

7
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)

2
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)

Loading…
Cancel
Save