From 3e12cd59cea428206df66bb088585b50f24fce2f Mon Sep 17 00:00:00 2001 From: Sipke Schoorstra Date: Tue, 9 Feb 2021 18:46:50 +0100 Subject: [PATCH] Remove rescheduling for now --- .../Elsa.Core/Consumers/RunWorkflowInstanceConsumer.cs | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) 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; }