|
|
|
@ -18,13 +18,19 @@ builder.Services.AddEndpointsApiExplorer();
|
|
|
|
builder.Services.AddSwaggerGen();
|
|
|
|
builder.Services.AddSwaggerGen();
|
|
|
|
|
|
|
|
|
|
|
|
var rabbitMqHost = builder.Configuration.GetSection("RabbitMq")["Host"];
|
|
|
|
var rabbitMqHost = builder.Configuration.GetSection("RabbitMq")["Host"];
|
|
|
|
|
|
|
|
var userName = builder.Configuration.GetSection("RabbitMq")["UserName"];
|
|
|
|
|
|
|
|
var password = builder.Configuration.GetSection("RabbitMq")["Password"];
|
|
|
|
builder.Services.AddMassTransit(opt =>
|
|
|
|
builder.Services.AddMassTransit(opt =>
|
|
|
|
{
|
|
|
|
{
|
|
|
|
opt.AddConsumersFromNamespaceContaining<DutyCompletionResultConsumer>();
|
|
|
|
opt.AddConsumersFromNamespaceContaining<DutyCompletionResultConsumer>();
|
|
|
|
|
|
|
|
|
|
|
|
opt.UsingRabbitMq((context, cfg) =>
|
|
|
|
opt.UsingRabbitMq((context, cfg) =>
|
|
|
|
{
|
|
|
|
{
|
|
|
|
cfg.Host(rabbitMqHost);
|
|
|
|
cfg.Host(rabbitMqHost, h =>
|
|
|
|
|
|
|
|
{
|
|
|
|
|
|
|
|
h.Username(userName);
|
|
|
|
|
|
|
|
h.Password(password);
|
|
|
|
|
|
|
|
});
|
|
|
|
cfg.ConfigureEndpoints(context);
|
|
|
|
cfg.ConfigureEndpoints(context);
|
|
|
|
});
|
|
|
|
});
|
|
|
|
});
|
|
|
|
});
|
|
|
|
|