We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 40787a1 commit f86a516Copy full SHA for f86a516
src/WorkflowCore/Services/BackgroundTasks/EventConsumer.cs
@@ -17,7 +17,7 @@ internal class EventConsumer : QueueConsumer, IBackgroundTask
17
private readonly IDistributedLockProvider _lockProvider;
18
private readonly IDateTimeProvider _datetimeProvider;
19
private readonly IGreyList _greylist;
20
- protected override int MaxConcurrentItems => 2;
+
21
protected override QueueType Queue => QueueType.Event;
22
23
public EventConsumer(IWorkflowRepository workflowRepository, ISubscriptionRepository subscriptionRepository, IEventRepository eventRepository, IQueueProvider queueProvider, ILoggerFactory loggerFactory, IServiceProvider serviceProvider, IWorkflowRegistry registry, IDistributedLockProvider lockProvider, WorkflowOptions options, IDateTimeProvider datetimeProvider, IGreyList greylist)
0 commit comments