Rename rabbit consumer class.

Author: runemalm

src/OpenDDD/Infrastructure/Events/RabbitMq/Factories/IRabbitMqConsumerFactory.cs

@@ -4,6 +4,6 @@ namespace OpenDDD.Infrastructure.Events.RabbitMq.Factories
 {
     public interface IRabbitMqConsumerFactory
     {
-        RabbitMqCustomAsyncConsumer CreateConsumer(IChannel channel, Func<string, CancellationToken, Task> messageHandler);
+        RabbitMqConsumer CreateConsumer(IChannel channel, Func<string, CancellationToken, Task> messageHandler);
     }
 }

src/OpenDDD/Infrastructure/Events/RabbitMq/Factories/RabbitMqConsumerFactory.cs

@@ -12,12 +12,12 @@ public RabbitMqConsumerFactory(ILogger<RabbitMqMessagingProvider> logger)
             _logger = logger ?? throw new ArgumentNullException(nameof(logger));
         }
 
-        public RabbitMqCustomAsyncConsumer CreateConsumer(IChannel channel, Func<string, CancellationToken, Task> messageHandler)
+        public RabbitMqConsumer CreateConsumer(IChannel channel, Func<string, CancellationToken, Task> messageHandler)
         {
             if (channel == null) throw new ArgumentNullException(nameof(channel));
             if (messageHandler == null) throw new ArgumentNullException(nameof(messageHandler));
 
-            return new RabbitMqCustomAsyncConsumer(channel, messageHandler, _logger);
+            return new RabbitMqConsumer(channel, messageHandler, _logger);
         }
     }
 }

…/RabbitMq/RabbitMqCustomAsyncConsumer.cs …ture/Events/RabbitMq/RabbitMqConsumer.cssrc/OpenDDD/Infrastructure/Events/RabbitMq/RabbitMqCustomAsyncConsumer.cs renamed to src/OpenDDD/Infrastructure/Events/RabbitMq/RabbitMqConsumer.cs src/OpenDDD/Infrastructure/Events/RabbitMq/RabbitMqCustomAsyncConsumer.cs renamed to src/OpenDDD/Infrastructure/Events/RabbitMq/RabbitMqConsumer.cs

@@ -5,15 +5,15 @@
 
 namespace OpenDDD.Infrastructure.Events.RabbitMq
 {
-    public class RabbitMqCustomAsyncConsumer : IAsyncBasicConsumer, IAsyncDisposable
+    public class RabbitMqConsumer : IAsyncBasicConsumer, IAsyncDisposable
     {
         private readonly Func<string, CancellationToken, Task> _messageHandler;
         private readonly ILogger<RabbitMqMessagingProvider> _logger;
         private readonly IChannel _channel;
         private string? _consumerTag;
         private bool _disposed;
 
-        public RabbitMqCustomAsyncConsumer(
+        public RabbitMqConsumer(
             IChannel channel, 
             Func<string, CancellationToken, Task> messageHandler, 
             ILogger<RabbitMqMessagingProvider> logger)

src/OpenDDD/Infrastructure/Events/RabbitMq/RabbitMqSubscription.cs

@@ -2,9 +2,9 @@
 
 namespace OpenDDD.Infrastructure.Events.RabbitMq
 {
-    public class RabbitMqSubscription : Subscription<RabbitMqCustomAsyncConsumer>
+    public class RabbitMqSubscription : Subscription<RabbitMqConsumer>
     {
-        public RabbitMqSubscription(string topic, string consumerGroup, RabbitMqCustomAsyncConsumer consumer) 
+        public RabbitMqSubscription(string topic, string consumerGroup, RabbitMqConsumer consumer) 
             : base(topic, consumerGroup, consumer) { }
 
         public override async ValueTask DisposeAsync()