SemianiakaVY/elsa-core
1
0
Fork 0
Code Issues Pull requests Actions 1 Packages Projects Releases Wiki Activity

Add toggle for WorkflowInboxCleanupJob in WorkflowRuntimeFeature

Browse source 
Introduced methods to enable or disable the WorkflowInboxCleanupJob. Updated service configuration logic to conditionally register WorkflowInboxCleanupHostedService based on the toggle. This adds flexibility to control cleanup job behavior programmatically.
This commit is contained in:
Sipke Schoorstra 2025-02-17 19:04:10 +01:00
parent 6682b7f60f
commit 0065811354
1 changed files with 23 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

31
src/modules/Elsa.Workflows.Runtime/Features/WorkflowRuntimeFeature.cs
View file

@ -29,12 +29,9 @@ namespace Elsa.Workflows.Runtime.Features;
/// Installs and configures workflow runtime features.
/// </summary>
[DependsOn(typeof(SystemClockFeature))]
public class WorkflowRuntimeFeature : FeatureBase
public class WorkflowRuntimeFeature(IModule module) : FeatureBase(module)
{
/// <inheritdoc />
public WorkflowRuntimeFeature(IModule module) : base(module)
{
}
private bool _enableWorkflowInboxCleanupJob = true;
private IDictionary<string, DispatcherChannel> WorkflowDispatcherChannels { get; set; } = new Dictionary<string, DispatcherChannel>();
@ -126,12 +123,30 @@ public class WorkflowRuntimeFeature : FeatureBase
/// A delegate to configure the <see cref="WorkflowInboxCleanupOptions"/>.
/// </summary>
public Action<WorkflowInboxCleanupOptions> WorkflowInboxCleanupOptions { get; set; } = _ => { };
/// <summary>
/// A delegate to configure the <see cref="WorkflowDispatcherOptions"/>.
/// </summary>
public Action<WorkflowDispatcherOptions> WorkflowDispatcherOptions { get; set; } = _ => { };
/// <summary>
/// Enables the workflow inbox cleanup job.
/// </summary>
public WorkflowRuntimeFeature EnableWorkflowInboxCleanupJob()
{
_enableWorkflowInboxCleanupJob = true;
return this;
}
/// <summary>
/// Disables the workflow inbox cleanup job.
/// </summary>
public WorkflowRuntimeFeature DisableWorkflowInboxCleanupJob()
{
_enableWorkflowInboxCleanupJob = false;
return this;
}
/// <summary>
/// Register the specified workflow type.
/// </summary>
@ -188,7 +203,7 @@ public class WorkflowRuntimeFeature : FeatureBase
public override void ConfigureHostedServices()
{
Module.ConfigureHostedService<PopulateRegistriesHostedService>();
Module.ConfigureHostedService<WorkflowInboxCleanupHostedService>();
if (_enableWorkflowInboxCleanupJob) Module.ConfigureHostedService<WorkflowInboxCleanupHostedService>();
}
/// <inheritdoc />
@ -240,7 +255,7 @@ public class WorkflowRuntimeFeature : FeatureBase
.AddScoped<IWorkflowCancellationService, WorkflowCancellationService>()
.AddScoped<ILogRecordExtractor<ActivityExecutionRecord>, ActivityExecutionRecordExtractor>()
.AddScoped<ILogRecordExtractor<WorkflowExecutionLogRecord>, WorkflowExecutionLogRecordExtractor>()
// Stores.
.AddScoped(BookmarkStore)
.AddScoped(TriggerStore)