From 42e9361f1d7cba942f1dfaf00a87ea5b2c91054d Mon Sep 17 00:00:00 2001 From: TekH Date: Thu, 23 Jul 2026 16:55:04 +0200 Subject: [PATCH] Refactor RabbitMqEmailQueue to OutgoingEmailQueue Replaced `RabbitMqEmailQueue` with `OutgoingEmailQueue` in the dependency injection container to reflect the updated class name. Renamed the class `RabbitMqEmailQueue` to `OutgoingEmailQueue` in `OutgoingEmailQueue.cs`, including updates to the constructor and logger type. This refactor aligns the class name with its purpose and improves clarity in the codebase. --- .../DependencyInjection.cs | 2 +- .../Queue/{RabbitMqEmailQueue.cs => OutgoingEmailQueue.cs} | 6 +++--- 2 files changed, 4 insertions(+), 4 deletions(-) rename src/DigitalData.EmailProfiler.Infrastructure/Queue/{RabbitMqEmailQueue.cs => OutgoingEmailQueue.cs} (97%) diff --git a/src/DigitalData.EmailProfiler.Infrastructure/DependencyInjection.cs b/src/DigitalData.EmailProfiler.Infrastructure/DependencyInjection.cs index e724498..48ad61a 100644 --- a/src/DigitalData.EmailProfiler.Infrastructure/DependencyInjection.cs +++ b/src/DigitalData.EmailProfiler.Infrastructure/DependencyInjection.cs @@ -31,7 +31,7 @@ public static class DependencyInjection services.AddSingleton(); // --- Email Queue (RabbitMQ) --- - services.AddSingleton(); + services.AddSingleton(); // --- RabbitMQ Configuration --- services.Configure( diff --git a/src/DigitalData.EmailProfiler.Infrastructure/Queue/RabbitMqEmailQueue.cs b/src/DigitalData.EmailProfiler.Infrastructure/Queue/OutgoingEmailQueue.cs similarity index 97% rename from src/DigitalData.EmailProfiler.Infrastructure/Queue/RabbitMqEmailQueue.cs rename to src/DigitalData.EmailProfiler.Infrastructure/Queue/OutgoingEmailQueue.cs index d6025c8..5377fd4 100644 --- a/src/DigitalData.EmailProfiler.Infrastructure/Queue/RabbitMqEmailQueue.cs +++ b/src/DigitalData.EmailProfiler.Infrastructure/Queue/OutgoingEmailQueue.cs @@ -16,16 +16,16 @@ namespace DigitalData.EmailProfiler.Infrastructure.Queue; /// Provides message persistence, scalability, and reliability. /// Uses Lazy initialization pattern to avoid blocking constructor. /// -public class RabbitMqEmailQueue : IEmailQueue, IDisposable +public class OutgoingEmailQueue : IEmailQueue, IDisposable { - private readonly ILogger _logger; + private readonly ILogger _logger; private readonly RabbitMqConfiguration _config; private IConnection? _connection; private IChannel _channel; private readonly IEmailService _emailService; #pragma warning disable CS8618 // channel and connection are initialized in InitAsync, not in constructor - public RabbitMqEmailQueue(IOptions config, ILogger logger, IEmailService emailService) + public OutgoingEmailQueue(IOptions config, ILogger logger, IEmailService emailService) #pragma warning restore CS8618 { _logger = logger;