MassTransit Alterations Dispatcher #4547
Merged
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
This PR adds a MassTransit implementation for the alteration job dispatcher service. This allows the engine to scale out into multiple application containers to increase throughput and resiliency.
=== auto-pr-body ===
Summary
This pull request includes a set of changes and additions related to the MassTransit feature, implemented to allow running alteration jobs in the background. Changes include adding a
FindManyIdsAsync
method toIAlterationJobStore
, refactoring fields such asAlterationPlan.Status
andAlterationJob.Status
to use strongly typed enums and configuring indexes on selected fields.List of Changes:
Elsa.Alterations.MassTransit
project to solution fileRunAlterationJob
message toElsa.Alterations.MassTransit.Messages
ResumeWorkflowInstance
handlerDispatchWorkflowRequestConsumer
toElsa.Alterations.MassTransit.Features
AlterationJobStore
andAlterationPlan
FindManyIdsAsync
method toAlterationJobStore
MassTransitAlterationsFeature
,UseMassTransit
andAddMassTransitConsumer
methods toModuleExtensions
Suggested Refactorings/Modifications:
AlterationPlan
andAlterationJob
configurationsAlterationPlan.Status
andAlterationJob.Status
fields