Skip to content

Commit 28da909

Browse files
committed
Improves dead letter logging in InMemoryQueue
Refines the logging message when a message exceeds the retry limit and is moved to the dead letter queue in the InMemoryQueue. The log message now includes the number of attempts and the configured retries for better clarity.
1 parent 048b7ce commit 28da909

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/Foundatio/Queues/InMemoryQueue.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -231,7 +231,7 @@ protected override async Task<IQueueEntry<T>> DequeueImplAsync(CancellationToken
231231

232232
if (entry.Attempts > _options.Retries + 1)
233233
{
234-
_logger.LogInformation("Exceeded retry limit ({Attempts} attempts, {Retries} retries), auto dead lettering: {QueueEntryId}", entry.Attempts, _options.Retries, entry.Id);
234+
_logger.LogInformation("Exceeded retry limit ({Attempts}/{Retries}), moving message {QueueEntryId} to dead letter", entry.Attempts, _options.Retries, entry.Id);
235235
_deadletterQueue.Enqueue(entry);
236236
Interlocked.Increment(ref _abandonedCount);
237237
continue;
@@ -338,7 +338,7 @@ public override async Task AbandonAsync(IQueueEntry<T> queueEntry)
338338
}
339339
else
340340
{
341-
_logger.LogTrace("Exceeded retry limit moving to deadletter: {QueueEntryId}", queueEntry.Id);
341+
_logger.LogInformation("Exceeded retry limit ({Attempts}/{Retries}), moving message {QueueEntryId} to dead letter", targetEntry.Attempts, _options.Retries, queueEntry.Id);
342342
_deadletterQueue.Enqueue(targetEntry);
343343
}
344344
}

0 commit comments

Comments
 (0)