/
ilyamikhaylov07
/
integration_solution_course
Обзор
Документация
Войти
/
ilyamikhaylov07
/
integration_solution_course
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
CI/CD
Аналитика
Безопасность
master
TaskAPI/Messaging/RabbitMqBackgroundService.cs
26 строк
897 B
Ilya
add 4 laba
02 ноя 2025, 19:16
02 ноя 2025, 19:16
fdd8d01
Код
Авторство
О чём код?
namespace TaskAPI.Messaging { public class RabbitMqBackgroundService : BackgroundService { private readonly IServiceScopeFactory _scopeFactory; private readonly RabbitMqService _rabbitMqService; public RabbitMqBackgroundService(IServiceScopeFactory scopeFactory, RabbitMqService rabbitMqService) { _scopeFactory = scopeFactory; _rabbitMqService = rabbitMqService; } protected override Task ExecuteAsync(CancellationToken stoppingToken) { _rabbitMqService.ConsumeAsync("api.requests", async body => { using var scope = _scopeFactory.CreateScope(); var server = scope.ServiceProvider.GetRequiredService<TaskApiServer>(); await server.HandleMessageAsync(body); }); return Task.CompletedTask; } } }