/
vshmidt
/
masstransit
Обзор
Документация
Войти
/
vshmidt
/
masstransit
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
develop
src/MassTransit.TestFramework/Futures/ProcessBatchItemConsumer.cs
29 строк
761 B
mikemao
Added WhenAllCompletedOrFaulted to Durable Future
26 апр 2024, 22:07
26 апр 2024, 22:07
1050df6
Код
Авторство
О чём код?
namespace MassTransit.TestFramework.Futures; using System; using System.Threading.Tasks; public class ProcessBatchItemConsumer : IConsumer<ProcessBatchItem> { public Task Consume(ConsumeContext<ProcessBatchItem> context) { async Task WaitAndRespond(int milliSecond) { await Task.Delay(milliSecond); await context.RespondAsync<ProcessBatchItemCompleted>(new { context.Message.CorrelationId, context.Message.JobNumber }); } return context.Message.JobNumber switch { "Delay" => WaitAndRespond(2000), "Error" => throw new InvalidOperationException(), _ => WaitAndRespond(0) }; } }