Khwezi Mngoma
acc0d44c7c
Internal service bus support enabled Added quartz support Reconfigured extensions
22 lines
641 B
C#
22 lines
641 B
C#
using LiteCharms.Abstractions;
|
|
|
|
namespace LiteCharms.Infrastructure.Quartz;
|
|
|
|
[DisallowConcurrentExecution]
|
|
public class MediatorJob<TNotification>(IMediator mediator) : IJob where TNotification : IEvent
|
|
{
|
|
public async Task Execute(IJobExecutionContext context)
|
|
{
|
|
var data = context.MergedJobDataMap["Payload"] as string;
|
|
|
|
if (string.IsNullOrWhiteSpace(data)) return;
|
|
|
|
var notification = JsonSerializer.Deserialize<TNotification>(data);
|
|
|
|
if(notification is null) return;
|
|
|
|
if(notification is TNotification)
|
|
await mediator.Publish(notification, context.CancellationToken);
|
|
}
|
|
}
|