Код: Выделить всё
protected override async Task ExecuteAsync(
CancellationToken stoppingToken)
{
using var channel = await _mqFactory.CreateChannel(...);
await channel.QueueDeclareAsync(...);
await channel.BasicQosAsync(...);
var consumer = new AsyncEventingBasicConsumer(channel);
consumer.ReceivedAsync += async (ch, ea) => { ... };
await channel.BasicConsumeAsync(...);
while (!stoppingToken.IsCancellationRequested)
{
// spin and wait
}
await channel.CloseAsync();
}
Подробнее здесь: https://stackoverflow.com/questions/796 ... er-waiting