Merge pull request 'Implemented startup jobs' (#13) from migration into master
Reviewed-on: #13
This commit was merged in pull request #13.
This commit is contained in:
@@ -8,7 +8,7 @@
|
|||||||
</PropertyGroup>
|
</PropertyGroup>
|
||||||
|
|
||||||
<ItemGroup>
|
<ItemGroup>
|
||||||
<PackageReference Include="LiteCharms.Abstractions" Version="1.14.0" />
|
<PackageReference Include="LiteCharms.Abstractions" Version="1.19.0" />
|
||||||
<PackageReference Include="Microsoft.Extensions.Hosting" Version="10.0.7" />
|
<PackageReference Include="Microsoft.Extensions.Hosting" Version="10.0.7" />
|
||||||
<PackageReference Include="Mediator.SourceGenerator" Version="3.0.2">
|
<PackageReference Include="Mediator.SourceGenerator" Version="3.0.2">
|
||||||
<PrivateAssets>all</PrivateAssets>
|
<PrivateAssets>all</PrivateAssets>
|
||||||
@@ -18,9 +18,9 @@
|
|||||||
|
|
||||||
<!-- Lite Charms Libraries -->
|
<!-- Lite Charms Libraries -->
|
||||||
<ItemGroup>
|
<ItemGroup>
|
||||||
<PackageReference Include="LiteCharms.Extensions" Version="1.14.0" />
|
<PackageReference Include="LiteCharms.Extensions" Version="1.19.0" />
|
||||||
<PackageReference Include="LiteCharms.Features" Version="1.14.0" />
|
<PackageReference Include="LiteCharms.Features" Version="1.19.0" />
|
||||||
<PackageReference Include="LiteCharms.Models" Version="1.14.0" />
|
<PackageReference Include="LiteCharms.Models" Version="1.19.0" />
|
||||||
</ItemGroup>
|
</ItemGroup>
|
||||||
|
|
||||||
<!-- Shared Global Usings -->
|
<!-- Shared Global Usings -->
|
||||||
|
|||||||
@@ -12,7 +12,7 @@ builder.Services.AddEmailServices(builder.Configuration);
|
|||||||
builder.Services.AddShopDatabase(builder.Configuration);
|
builder.Services.AddShopDatabase(builder.Configuration);
|
||||||
builder.Services.AddQuartzSchedulerClient(ShopSchedulerName, builder.Configuration);
|
builder.Services.AddQuartzSchedulerClient(ShopSchedulerName, builder.Configuration);
|
||||||
|
|
||||||
builder.Services.AddHostedService<Worker>();
|
builder.Services.AddHostedService<JobWorker>();
|
||||||
|
|
||||||
var host = builder.Build();
|
var host = builder.Build();
|
||||||
|
|
||||||
|
|||||||
@@ -0,0 +1,15 @@
|
|||||||
|
using LiteCharms.Abstractions;
|
||||||
|
using LiteCharms.Features.Notifications.Events;
|
||||||
|
|
||||||
|
namespace LiteCharmsScheduler.Workers
|
||||||
|
{
|
||||||
|
public class JobWorker(IJobOrchestrator jobOrchestrator, ILogger<JobWorker> logger) : BackgroundService
|
||||||
|
{
|
||||||
|
protected override async Task ExecuteAsync(CancellationToken stoppingToken)
|
||||||
|
{
|
||||||
|
await jobOrchestrator.ScheduleAsync(ProcessEmailNotificationsEvent.Create(), "0 1 * * * ?", stoppingToken);
|
||||||
|
|
||||||
|
logger.LogInformation("Startup jobs scheduled");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -1,17 +0,0 @@
|
|||||||
namespace LiteCharmsScheduler.Workers
|
|
||||||
{
|
|
||||||
public class Worker(ILogger<Worker> logger) : BackgroundService
|
|
||||||
{
|
|
||||||
protected override async Task ExecuteAsync(CancellationToken stoppingToken)
|
|
||||||
{
|
|
||||||
while (!stoppingToken.IsCancellationRequested)
|
|
||||||
{
|
|
||||||
if (logger.IsEnabled(LogLevel.Information))
|
|
||||||
{
|
|
||||||
logger.LogInformation("Worker running at: {time}", DateTimeOffset.Now);
|
|
||||||
}
|
|
||||||
await Task.Delay(1000, stoppingToken);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
Reference in New Issue
Block a user