This commit is contained in:
@@ -3,15 +3,17 @@ using LiteCharms.Features.Shop.Notifications.Events;
|
||||
|
||||
namespace LiteCharmsScheduler.Workers
|
||||
{
|
||||
public class JobWorker(IJobOrchestrator jobOrchestrator, ILogger<JobWorker> logger) : BackgroundService
|
||||
public class JobWorker(IJobOrchestrator jobOrchestrator, ILogger<JobWorker> logger, IConfiguration configuration) : BackgroundService
|
||||
{
|
||||
private const string emailProcessorCron = "0 */5 * * * ?";
|
||||
|
||||
protected override async Task ExecuteAsync(CancellationToken stoppingToken)
|
||||
{
|
||||
string? emailProcessorCron = !string.IsNullOrWhiteSpace(configuration.GetSection("EmailProcessorCron").Value)
|
||||
? configuration.GetSection("EmailProcessorCron").Value
|
||||
: "0 */4 * * * ?";
|
||||
|
||||
var emailProcessorJob = ProcessEmailNotificationsEvent.Create();
|
||||
|
||||
await jobOrchestrator.ScheduleAsync(emailProcessorJob, emailProcessorCron, stoppingToken);
|
||||
await jobOrchestrator.ScheduleAsync(emailProcessorJob, emailProcessorCron!, stoppingToken);
|
||||
|
||||
logger.LogInformation("Startup jobs scheduled");
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user