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<RabbitMqConfiguration> config
     /// </summary>
     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<RabbitMqConfiguration> confi
     /// </summary>
     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<IConnection> GetConnectionAsync()
+        public Task<IConnection> 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()