TickerQ Background Worker Manager

TickerQ is a fast, reflection-free background task scheduler for .NET — built with source generators, EF Core integration, cron + time-based execution, and a real-time dashboard. You can integrate TickerQ with the ABP to use it instead of the default background worker manager.

Installation

It is suggested to use the ABP CLI to install this package.

Using the ABP CLI

Open a command line window in the folder of the project (.csproj file) and type the following command:

abp add-package Volo.Abp.BackgroundWorkers.TickerQ

If you haven't done it yet, you first need to install the ABP CLI. For other installation options, see the package description page.

Configuration

AddTickerQ

You can call the AddTickerQ extension method in the ConfigureServices method of your module to configure TickerQ services:

This is optional. ABP will automatically register TickerQ services.

public override void ConfigureServices(ServiceConfigurationContext context)
{
	context.Services.AddTickerQ(x =>
	{
		// Configure TickerQ options here
	});
}

UseAbpTickerQ

You need to call the UseAbpTickerQ extension method instead of AddTickerQ in the OnApplicationInitialization method of your module:

// (default: TickerQStartMode.Immediate)
app.UseAbpTickerQ(startMode: ...);

AbpBackgroundWorkersTickerQOptions

You can configure the CronTicker properties for specific jobs. For example, Change Priority, Retries and RetryIntervals properties:

Configure<AbpBackgroundWorkersTickerQOptions>(options =>
{
	options.AddConfiguration<MyBackgroundWorker>(new AbpBackgroundWorkersCronTickerConfiguration()
	{
		Retries = 3,
		RetryIntervals = new[] {30, 60, 120}, // Retry after 30s, 60s, then 2min,
		Priority = TickerTaskPriority.High
	});
});

Add your own TickerQ Background Worker Definitions

ABP will handle the TickerQ job definitions by AbpTickerQFunctionProvider service. You shouldn't use TickerFunction to add your own job definitions. You can inject and use the AbpTickerQFunctionProvider to add your own definitions and use ITimeTickerManager<TimeTicker> or ICronTickerManager<CronTicker> to manage the jobs.

For example, you can add a CleanupJobs job definition in the OnPreApplicationInitializationAsync method of your module:

public class CleanupJobs
{
    public async Task CleanupLogsAsync(TickerFunctionContext<string> tickerContext, CancellationToken cancellationToken)
    {
        var logFileName = tickerContext.Request;
        Console.WriteLine($"Cleaning up log file: {logFileName} at {DateTime.Now}");
    }
}

public override Task OnPreApplicationInitializationAsync(ApplicationInitializationContext context)
{
	var abpTickerQFunctionProvider = context.ServiceProvider.GetRequiredService<AbpTickerQFunctionProvider>();
	abpTickerQFunctionProvider.Functions.TryAdd(nameof(CleanupJobs), (string.Empty, TickerTaskPriority.Normal, new TickerFunctionDelegate(async (cancellationToken, serviceProvider, tickerFunctionContext) =>
	{
		var service = new CleanupJobs(); // Or get it from the serviceProvider
		var request = await TickerRequestProvider.GetRequestAsync<string>(serviceProvider,  tickerFunctionContext.Id, tickerFunctionContext.Type);
		var genericContext = new TickerFunctionContext<string>(tickerFunctionContext, request);
		await service.CleanupLogsAsync(genericContext, cancellationToken);
	})));
	abpTickerQFunctionProvider.RequestTypes.TryAdd(nameof(CleanupJobs), (typeof(string).FullName, typeof(string)));
	return Task.CompletedTask;
}

And then you can add a job by using the ICronTickerManager<CronTicker>:

var cronTickerManager = context.ServiceProvider.GetRequiredService<ICronTickerManager<CronTicker>>();
await cronTickerManager.AddAsync(new CronTicker
{
	Function = nameof(CleanupJobs),
	Expression = "0 */6 * * *", // Every 6 hours
	Request = TickerHelper.CreateTickerRequest<string>("cleanup_example_file.txt"),
	Retries = 2,
	RetryIntervals = new[] { 60, 300 }
});

You can specify a cron expression instead of use ICronTickerManager<CronTicker> to add a worker:

abpTickerQFunctionProvider.Functions.TryAdd(nameof(CleanupJobs), (string.Empty, TickerTaskPriority.Normal, new TickerFunctionDelegate(async (cancellationToken, serviceProvider, tickerFunctionContext) =>
{
	var service = new CleanupJobs();
	var request = await TickerRequestProvider.GetRequestAsync<string>(serviceProvider,  tickerFunctionContext.Id, tickerFunctionContext.Type);
	var genericContext = new TickerFunctionContext<string>(tickerFunctionContext, request);
	await service.CleanupLogsAsync(genericContext, cancellationToken);
})));