Skip to content

Commit

Permalink
Use brackets. Return on own line.
Browse files Browse the repository at this point in the history
  • Loading branch information
brendonparker authored Aug 2, 2024
1 parent 7d40de7 commit d8b2a92
Showing 1 changed file with 8 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -264,11 +264,15 @@ public async Task DeleteMessagesAsync(IEnumerable<MessageEnvelope> messages, Can
/// </summary>
private async Task ResetVisibilityTimeoutForFailures()
{
if (_configuration.SQSEvent == null) return;
if (!_configuration.UseBatchResponse) return;
if (!_configuration.VisibilityTimeoutForBatchFailures.HasValue) return;
if (_configuration.SQSEvent == null || !_configuration.UseBatchResponse || !_configuration.VisibilityTimeoutForBatchFailures.HasValue)
{
return;
}
var failureCount = _sqsBatchResponse.BatchItemFailures?.Count ?? 0;
if (failureCount == 0) return;
if (failureCount == 0)
{
return;
}

var lookup = _configuration.SQSEvent.Records.ToDictionary(x => x.MessageId);
var visibilityTimeout = _configuration.VisibilityTimeoutForBatchFailures.Value;
Expand Down

0 comments on commit d8b2a92

Please sign in to comment.