From a2373f242a6148229fe9b2b3a0f62da3b44ed1b1 Mon Sep 17 00:00:00 2001 From: TekH Date: Mon, 27 Jul 2026 13:05:17 +0200 Subject: [PATCH] Refactor RabbitMQ connection handling logic Updated `OutgoingEmailConsumer` and `OutgoingEmailPublisher` to use `GetDefaultConnectionAsync` instead of `GetConnectionAsync` for initializing RabbitMQ connections. Renamed `GetConnectionAsync` to `GetDefaultConnectionAsync` in `RabbitMqConnectionFactory` to improve clarity and align with naming conventions. Updated `InitAsync` in `RabbitMqConnectionFactory` to use the renamed method. These changes improve consistency, maintainability, and clarity in RabbitMQ connection management. --- .../Queue/OutgoingEmailConsumer.cs | 2 +- .../Queue/OutgoingEmailPublisher.cs | 2 +- .../RabbitMqConnectionFactory.cs | 4 ++-- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/src/DigitalData.MessagingService.Infrastructure/Queue/OutgoingEmailConsumer.cs b/src/DigitalData.MessagingService.Infrastructure/Queue/OutgoingEmailConsumer.cs index 26fa488..b4daafe 100644 --- a/src/DigitalData.MessagingService.Infrastructure/Queue/OutgoingEmailConsumer.cs +++ b/src/DigitalData.MessagingService.Infrastructure/Queue/OutgoingEmailConsumer.cs @@ -27,7 +27,7 @@ public sealed class OutgoingEmailConsumer(IOptions config /// public async Task InitAsync() { - var connection = await CnnFactory.GetConnectionAsync(); + var connection = await CnnFactory.GetDefaultConnectionAsync(); var stoppingToken = CnnFactory.CancellationToken; diff --git a/src/DigitalData.MessagingService.Infrastructure/Queue/OutgoingEmailPublisher.cs b/src/DigitalData.MessagingService.Infrastructure/Queue/OutgoingEmailPublisher.cs index 545504c..b31219a 100644 --- a/src/DigitalData.MessagingService.Infrastructure/Queue/OutgoingEmailPublisher.cs +++ b/src/DigitalData.MessagingService.Infrastructure/Queue/OutgoingEmailPublisher.cs @@ -28,7 +28,7 @@ public sealed class OutgoingEmailPublisher(IOptions confi /// public async Task InitAsync() { - var connection = await CnnFactory.GetConnectionAsync(); + var connection = await CnnFactory.GetDefaultConnectionAsync(); var stoppingToken = CnnFactory.CancellationToken; diff --git a/src/DigitalData.MessagingService.RabbitMQ/RabbitMqConnectionFactory.cs b/src/DigitalData.MessagingService.RabbitMQ/RabbitMqConnectionFactory.cs index f4d5817..a5bbca6 100644 --- a/src/DigitalData.MessagingService.RabbitMQ/RabbitMqConnectionFactory.cs +++ b/src/DigitalData.MessagingService.RabbitMQ/RabbitMqConnectionFactory.cs @@ -30,7 +30,7 @@ namespace DigitalData.MessagingService.RabbitMQ public CancellationToken CancellationToken => _cancellationToken ?? throw new InvalidOperationException("RabbitMqConnectionFactory is not initialized. Call InitAsync() before using this method."); - public Task GetConnectionAsync() + public Task GetDefaultConnectionAsync() { if (_cancellationToken != null) return _lazyConnectionProvider.Value; @@ -67,7 +67,7 @@ namespace DigitalData.MessagingService.RabbitMQ public async Task InitAsync(CancellationToken cancellationToken = default) { _cancellationToken = cancellationToken; - _ = await GetConnectionAsync(); + _ = await GetDefaultConnectionAsync(); } public async ValueTask DisposeAsync()