Merge pull request #24 from AntonyVorontsov/feature/message-handler-ordering

Added message handler ordering.

Author: antonyvorontsov

examples/Examples.ConsumerConsole/CustomAsyncMessageHandler.cs

@@ -15,7 +15,7 @@ public CustomAsyncMessageHandler(ILogger<CustomAsyncMessageHandler> logger)
 
         public async Task Handle(string message, string routingKey)
         {
-            _logger.LogInformation($"A weird example of running something async with message {message}.");
+            _logger.LogInformation($"A weird example of running something async with message {message} that has been received by {routingKey}.");
             await Task.CompletedTask.ConfigureAwait(false);
         }
     }

examples/Examples.ConsumerHost/CustomMessageHandler.cs

@@ -13,7 +13,7 @@ public CustomMessageHandler(ILogger<CustomMessageHandler> logger)
 
         public void Handle(string message, string routingKey)
         {
-            _logger.LogInformation("Handling messages");
+            _logger.LogInformation($"Handling message {message} by routing key {routingKey}");
         }
     }
 }

examples/Examples.Producer/Message.cs

@@ -7,6 +7,8 @@ public class Message
         public string Name { get; set; }
 
         public bool Flag { get; set; }
+        
+        public int Index { get; set; }
 
         public IEnumerable<int> Numbers { get; set; }
     }

examples/Examples.Producer/Program.cs

@@ -16,13 +16,17 @@ public static async Task Main()
             var serviceProvider = serviceCollection.BuildServiceProvider();
             var queueService = serviceProvider.GetRequiredService<IQueueService>();
 
-            var message = new Message
+            for (var i = 0; i < 10; i++)
             {
-                Name = "Custom message",
-                Flag = true,
-                Numbers = new[] { 1, 2, 3 }
-            };
-            await queueService.SendAsync(message, "exchange.name", "routing.key");
+                var message = new Message
+                {
+                    Name = "Custom message",
+                    Flag = true,
+                    Index = i,
+                    Numbers = new[] { 1, 2, 3 }
+                };
+                await queueService.SendAsync(message, "exchange.name", "routing.key");
+            }
         }
 
         static void ConfigureServices(IServiceCollection services)

readme.md

@@ -175,10 +175,6 @@ Exchange sections define how to bind queues and exchanges with each other using
 
 For more information about `appsettings.json` and manual configuration features, see [rabbit-configuration](./docs/rabbit-configuration.md) and [exchange-configuration](./docs/exchange-configuration.md) documentation files.
 
-## Versioning
-
-For now this project uses semantic versioning that follows .Net Core versioning. That means that major and minor versions are equal to .Net Core major and minor versions but patch versions will be used independently.
-
 ## Changelog
 
 All notable changes are being tracked in the [changelog](./docs/changelog.md) file.

src/RabbitMQ.Client.Core.DependencyInjection/IAsyncMessageHandler.cs

@@ -5,7 +5,7 @@ namespace RabbitMQ.Client.Core.DependencyInjection
     /// <summary>
     /// Interface of asynchronous message handler.
     /// </summary>
-    public interface IAsyncMessageHandler
+    public interface IAsyncMessageHandler : IBaseMessageHandler
     {
         /// <summary>
         /// Handle message from a queue.

src/RabbitMQ.Client.Core.DependencyInjection/IAsyncNonCyclicMessageHandler.cs

@@ -5,7 +5,7 @@ namespace RabbitMQ.Client.Core.DependencyInjection
     /// <summary>
     /// Interface of a non-cycling async message handler.
     /// </summary>
-    public interface IAsyncNonCyclicMessageHandler
+    public interface IAsyncNonCyclicMessageHandler : IBaseMessageHandler
     {
         /// <summary>
         /// Handle message from a queue.

src/RabbitMQ.Client.Core.DependencyInjection/IBaseMessageHandler.cs

@@ -0,0 +1,9 @@
+namespace RabbitMQ.Client.Core.DependencyInjection
+{
+    /// <summary>
+    /// A base interface that unites all message handlers.
+    /// </summary>
+    public interface IBaseMessageHandler
+    {
+    }
+}

src/RabbitMQ.Client.Core.DependencyInjection/IMessageHandler.cs

@@ -3,7 +3,7 @@
     /// <summary>
     /// Interface of message handler.
     /// </summary>
-    public interface IMessageHandler
+    public interface IMessageHandler : IBaseMessageHandler
     {
         /// <summary>
         /// Handle message from a queue.

src/RabbitMQ.Client.Core.DependencyInjection/IMessageHandlingService.cs

@@ -1,3 +1,4 @@
+using System.Threading.Tasks;
 using RabbitMQ.Client.Events;
 
 namespace RabbitMQ.Client.Core.DependencyInjection
@@ -12,6 +13,6 @@ public interface IMessageHandlingService
         /// </summary>
         /// <param name="eventArgs">Arguments of message receiving event.</param>
         /// <param name="queueService">An instance of the queue service <see cref="IQueueService"/>.</param>
-        void HandleMessageReceivingEvent(BasicDeliverEventArgs eventArgs, IQueueService queueService);
+        Task HandleMessageReceivingEvent(BasicDeliverEventArgs eventArgs, IQueueService queueService);
     }
 }