Skip to content
This repository was archived by the owner on Apr 17, 2025. It is now read-only.

Commit 4b599ec

Browse files
committed
Fix
1 parent 0b95682 commit 4b599ec

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/NET6CustomLibrary/RabbitMQ/QueueListener.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@ internal class QueueListener<T> : BackgroundService where T : class
44
{
55
private readonly MessageManager messageManager;
66
private readonly MessageManagerSettings messageManagerSettings;
7-
private readonly ILogger logger;
7+
private readonly Microsoft.Extensions.Logging.ILogger logger;
88
private readonly IServiceProvider serviceProvider;
99
private readonly string queueName;
1010

@@ -47,10 +47,10 @@ protected override Task ExecuteAsync(CancellationToken stoppingToken)
4747

4848
var receiver = scope.ServiceProvider.GetRequiredService<IMessageReceiver<T>>();
4949
var response = JsonSerializer.Deserialize<T>(message.Body.Span, messageManagerSettings.JsonSerializerOptions ?? JsonOptions.Default);
50+
5051
await receiver.ReceiveAsync(response, stoppingToken);
5152

5253
messageManager.MarkAsComplete(message);
53-
5454
logger.LogDebug("Message processed");
5555
}
5656
catch (Exception ex)

0 commit comments

Comments
 (0)