gistlyn · September 3, 2024 02:34
diff --git a/_init b/_init
 dotnet add package ServiceStack.Jobs
diff --git a/Configure.BackgroundJobs.cs b/Configure.BackgroundJobs.cs
 using ServiceStack.Data;
 using ServiceStack.Jobs;
 using ServiceStack.Web;

 [assembly: HostingStartup(typeof(MyApp.ConfigureBackgroundJobs))]

 namespace MyApp;

 public class ConfigureBackgroundJobs : IHostingStartup
 {
    public void Configure(IWebHostBuilder builder) => builder
        .ConfigureServices(services => {
            services.AddPlugin(new CommandsFeature());
            services.AddPlugin(new BackgroundsJobFeature());
            services.AddHostedService<JobsHostedService>();
         }).ConfigureAppHost(afterAppHostInit: appHost => {
            var services = appHost.GetApplicationServices();
            var jobs = services.GetRequiredService<IBackgroundJobs>();
            // Example of registering a Recurring Job to run Every Hour
            //jobs.RecurringCommand<MyCommand>(Schedule.Hourly);
        });
 }

 public class JobsHostedService(ILogger<JobsHostedService> log, IBackgroundJobs jobs) : BackgroundService
 {
    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        await jobs.StartAsync(stoppingToken);
        
        using var timer = new PeriodicTimer(TimeSpan.FromSeconds(3));
        while (!stoppingToken.IsCancellationRequested && await timer.WaitForNextTickAsync(stoppingToken))
        {
            await jobs.TickAsync();
        }
    }
 }
	using ServiceStack.Data;
	using ServiceStack.Jobs;
	using ServiceStack.Web;

	[assembly: HostingStartup(typeof(MyApp.ConfigureBackgroundJobs))]

	namespace MyApp;

	public class ConfigureBackgroundJobs : IHostingStartup
	{
	public void Configure(IWebHostBuilder builder) => builder
	.ConfigureServices(services => {
	services.AddPlugin(new CommandsFeature());
	services.AddPlugin(new BackgroundsJobFeature());
	services.AddHostedService<JobsHostedService>();
	}).ConfigureAppHost(afterAppHostInit: appHost => {
	var services = appHost.GetApplicationServices();
	var jobs = services.GetRequiredService<IBackgroundJobs>();
	// Example of registering a Recurring Job to run Every Hour
	//jobs.RecurringCommand<MyCommand>(Schedule.Hourly);
	});
	}

	public class JobsHostedService(ILogger<JobsHostedService> log, IBackgroundJobs jobs) : BackgroundService
	{
	protected override async Task ExecuteAsync(CancellationToken stoppingToken)
	{
	await jobs.StartAsync(stoppingToken);

	using var timer = new PeriodicTimer(TimeSpan.FromSeconds(3));
	while (!stoppingToken.IsCancellationRequested && await timer.WaitForNextTickAsync(stoppingToken))
	{
	await jobs.TickAsync();
	}
	}
	}