diff --git a/src/NServiceBus.AwsLambda.SQS/AwsLambdaSQSEndpointConfiguration.cs b/src/NServiceBus.AwsLambda.SQS/AwsLambdaSQSEndpointConfiguration.cs index 72089b7..fa21c3e 100644 --- a/src/NServiceBus.AwsLambda.SQS/AwsLambdaSQSEndpointConfiguration.cs +++ b/src/NServiceBus.AwsLambda.SQS/AwsLambdaSQSEndpointConfiguration.cs @@ -5,7 +5,6 @@ using Amazon.SimpleNotificationService; using Amazon.SQS; using AwsLambda.SQS; - using NServiceBus.Logging; using Serialization; @@ -37,10 +36,7 @@ public AwsLambdaSQSEndpointConfiguration(string endpointName, IAmazonSQS sqsClie recoverabilityPolicy.SendFailedMessagesToErrorQueue = true; - // delayed delivery is disabled by default as the required FIFO queue might not exist - EndpointConfiguration.Recoverability() - .Delayed(c => c.NumberOfRetries(0)) - .CustomPolicy(recoverabilityPolicy.Invoke); + EndpointConfiguration.Recoverability().CustomPolicy(recoverabilityPolicy.Invoke); if (sqsClient is null && snsClient is null) {