diff --git a/src/WorkflowCore/Services/BackgroundTasks/EventConsumer.cs b/src/WorkflowCore/Services/BackgroundTasks/EventConsumer.cs index dd7323b01..b959a2625 100644 --- a/src/WorkflowCore/Services/BackgroundTasks/EventConsumer.cs +++ b/src/WorkflowCore/Services/BackgroundTasks/EventConsumer.cs @@ -17,7 +17,7 @@ internal class EventConsumer : QueueConsumer, IBackgroundTask private readonly IDistributedLockProvider _lockProvider; private readonly IDateTimeProvider _datetimeProvider; private readonly IGreyList _greylist; - protected override int MaxConcurrentItems => 2; + protected override QueueType Queue => QueueType.Event; public EventConsumer(IWorkflowRepository workflowRepository, ISubscriptionRepository subscriptionRepository, IEventRepository eventRepository, IQueueProvider queueProvider, ILoggerFactory loggerFactory, IServiceProvider serviceProvider, IWorkflowRegistry registry, IDistributedLockProvider lockProvider, WorkflowOptions options, IDateTimeProvider datetimeProvider, IGreyList greylist)