diff --git a/src/core/Elsa.Core/Consumers/RunWorkflowInstanceConsumer.cs b/src/core/Elsa.Core/Consumers/RunWorkflowInstanceConsumer.cs index c401f41a7..e724e53c1 100644 --- a/src/core/Elsa.Core/Consumers/RunWorkflowInstanceConsumer.cs +++ b/src/core/Elsa.Core/Consumers/RunWorkflowInstanceConsumer.cs @@ -9,6 +9,7 @@ using Elsa.Services; using Microsoft.Extensions.Logging; using NodaTime; using Rebus.Handlers; +using Rebus.Pipeline; namespace Elsa.Consumers { @@ -45,9 +46,9 @@ namespace Elsa.Consumers if (!await _distributedLockProvider.AcquireLockAsync(lockKey)) { - // Reschedule message. - _logger.LogDebug("Failed to acquire lock on workflow instance {WorkflowInstanceId}. Rescheduling message", workflowInstanceId); - await _commandSender.DeferAsync(message, Duration.FromSeconds(5)); + // TODO: Reschedule message if it's not a redelivery. + // var currentContext = MessageContext.Current; + _logger.LogDebug("Failed to acquire lock on workflow instance {WorkflowInstanceId}", workflowInstanceId); return; }