/
vshmidt
/
masstransit
Обзор
Документация
Войти
/
vshmidt
/
masstransit
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
develop
src/MassTransit.Abstractions/Scheduling/SchedulingExtensions.cs
43 строки
1 KB
ushenkodmitry
Quartz ScheduleId/ScheduleGroup added to headers
14 ноя 2022, 16:24
14 ноя 2022, 16:24
cd6a1b5
Код
Авторство
О чём код?
namespace MassTransit { using System; public static class SchedulingExtensions { public static Guid? GetSchedulingTokenId(this ConsumeContext context) { return context.Headers.Get(MessageHeaders.SchedulingTokenId, default(Guid?)); } public static DateTimeOffset? GetQuartzScheduled(this ConsumeContext context) { return context.Headers.Get(MessageHeaders.Quartz.Scheduled, default(DateTimeOffset?)); } public static DateTimeOffset? GetQuartzSent(this ConsumeContext context) { return context.Headers.Get(MessageHeaders.Quartz.Sent, default(DateTimeOffset?)); } public static DateTimeOffset? GetQuartzNextScheduled(this ConsumeContext context) { return context.Headers.Get(MessageHeaders.Quartz.NextScheduled, default(DateTimeOffset?)); } public static DateTimeOffset? GetQuartzPreviousSent(this ConsumeContext context) { return context.Headers.Get(MessageHeaders.Quartz.PreviousSent, default(DateTimeOffset?)); } public static string? GetQuartzScheduleId(this ConsumeContext context) { return context.Headers.Get(MessageHeaders.Quartz.ScheduleId, default(string?)); } public static string? GetQuartzScheduleGroup(this ConsumeContext context) { return context.Headers.Get(MessageHeaders.Quartz.ScheduleGroup, default(string?)); } } }