/
vshmidt
/
masstransit
Обзор
Документация
Войти
/
vshmidt
/
masstransit
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
develop
src/MassTransit/Middleware/DelayedMessageSchedulerFilter.cs
30 строк
887 B
Chris Patterson
Fixed #3832 (again) - this time, is more stain removing power (Azure Scheduled Message Cancel vs. Skip)
15 ноя 2022, 05:40
15 ноя 2022, 05:40
c0c761f
Код
Авторство
О чём код?
namespace MassTransit.Middleware { using System.Diagnostics; using System.Threading.Tasks; using Context; using Scheduling; public class DelayedMessageSchedulerFilter : IFilter<ConsumeContext> { public void Probe(ProbeContext context) { context.CreateFilterScope("delayedMessageScheduler"); } [DebuggerNonUserCode] public Task Send(ConsumeContext context, IPipe<ConsumeContext> next) { context.GetOrAddPayload<MessageSchedulerContext>(() => new ConsumeMessageSchedulerContext(context, SchedulerFactory)); return next.Send(context); } static IMessageScheduler SchedulerFactory(ConsumeContext context) { return new MessageScheduler(new DelayedScheduleMessageProvider(context), context.GetPayload<IBusTopology>()); } } }