MassTransit автоматически добавляет потребителей ⇐ C#

[Anonymous]

Я использую MassTransit для подключения к нашему RabbitMQ. В настоящее время я работаю над обобщением кода для 15 решений, которые его используют. Но я столкнулся с препятствием в части настройки. Оригинально это выглядело так:

Код: Выделить всё

  services.AddMassTransit(c =>
{
c.AddConsumer();
c.AddBus(provider => Bus.Factory.CreateUsingRabbitMq(cfg =>
{
cfg.UseHealthCheck(provider);
cfg.Host(MassTransitHelper.CreateRabbitMQEndpointUri(messageQueueSettings), h =>
{
h.Username(messageQueueSettings.Username);
h.Password(messageQueueSettings.Password);
});

cfg.PrefetchCount = (ushort) messageQueueSettings.PrefetchCount;
cfg.MessageTopology.SetEntityNameFormatter(new EntityNameFormatter());
cfg.ExchangeType = ExchangeType.Direct;

cfg.ReceiveEndpoint(NameFormatter.FormatQueueName("serviceName"), e =>
{
e.Bind(NameFormatter.FormatExchangeName()); //Bind to Exchange
e.UseMessageRetry(r => r.Incremental(5, 5.Seconds(), 10.Seconds()));
e.ExclusiveConsumer = false;
e.PrefetchCount = messageQueueSettings.PrefetchCount;
e.Consumer(provider);
e.UseCircuitBreaker(cb =>
{
cb.TripThreshold = 15;
cb.ActiveThreshold = 10;
cb.ResetInterval = 5.Minutes();
});
});
}));
});

На данный момент мне удалось обобщить это так:

Код: Выделить всё

services.AddMassTransit(c =>
{
c.AddConsumer();
c.AddBus(provider => Bus.Factory.CreateUsingRabbitMq(cfg =>
{
cfg.UseHealthCheck(provider);
MassTransitSetup.BasicSetup(cfg, messageQueueSettings);
MassTransitSetup.InitializeConsumer(cfg, messageQueueSettings, provider, 5, "report");
}));
});

Но мне не хватает того, что мне нравится иметь возможность автоматически добавлять всех потребителей, получая их из сборок, что мне нравится:

Код: Выделить всё

var types = AppDomain.CurrentDomain.GetAssemblies()
.SelectMany(s => s.GetTypes())
.Where(p => typeof(IConsumer).IsAssignableFrom(p) && p.IsClass && !p.IsAbstract && p.Namespace!.Contains("MST.Hepper.")).ToList();

Но моя проблема заключается в том, как выполнить итерацию и добавить c.AddConsumer(); или MassTransitSetup.InitializeConsumer

Подробнее здесь: https://stackoverflow.com/questions/666 ... -consumers