Added example projects (non-cyclic handlers).

Author: antonyvorontsov

README.md

@@ -152,7 +152,7 @@ public class CustomAsyncMessageHandler : IAsyncMessageHandler
 }
 ```
 
-But you can not use `IQueueService` inside those message handlers otherwise you will be faced with cycling dependency problem. But sometimes you may need to send something in other queue (e.g. queue with responses) from one message handler or another. For that purposes use non-cyclinc handlers.
+But you can not use `IQueueService` inside those message handlers otherwise you will be faced with cycling dependency problem. But sometimes you may need to send something in other queue (e.g. queue with responses) from one message handler or another. For that purpose use non-cyclinc handlers.
 
 ```csharp
 public class CustomMessageHandler : INonCyclicMessageHandler

src/Examples.ConsumerConsole/CustomAsyncNonCyclicMessageHandler.cs

@@ -0,0 +1,21 @@
+using Microsoft.Extensions.Logging;
+using RabbitMQ.Client.Core.DependencyInjection;
+using System.Threading.Tasks;
+
+namespace Examples.ConsumerConsole
+{
+    public class CustomAsyncNonCyclicMessageHandler : IAsyncNonCyclicMessageHandler
+    {
+        readonly ILogger<CustomAsyncNonCyclicMessageHandler> _logger;
+
+        public CustomAsyncNonCyclicMessageHandler(ILogger<CustomAsyncNonCyclicMessageHandler> logger) =>
+            _logger = logger;
+
+        public async Task Handle(string message, string routingKey, IQueueService queueService)
+        {
+            _logger.LogInformation("A weird example of runnig something async.");
+            var response = new { message, routingKey };
+            await queueService.SendAsync(response, "exchange.name", "routing.key");
+        }
+    }
+}

src/Examples.ConsumerConsole/Program.cs

@@ -32,7 +32,8 @@ static void ConfigureServices(IServiceCollection services)
 
             services.AddRabbitMqClient(rabbitMqSection)
                 .AddExchange("exchange.name", exchangeSection)
-                .AddAsyncMessageHandlerSingleton<CustomAsyncMessageHandler>("routing.key");
+                .AddAsyncMessageHandlerSingleton<CustomAsyncMessageHandler>("routing.key")
+                .AddAsyncNonCyclicMessageHandlerSingleton<CustomAsyncNonCyclicMessageHandler>("routing.key");
         }
     }
 }

src/Examples.ConsumerHost/CustomNonCyclicMessageHandler.cs

@@ -0,0 +1,19 @@
+using Microsoft.Extensions.Logging;
+using RabbitMQ.Client.Core.DependencyInjection;
+
+namespace Examples.ConsumerHost
+{
+    public class CustomNonCyclicMessageHandler : INonCyclicMessageHandler
+    {
+        readonly ILogger<CustomNonCyclicMessageHandler> _logger;
+        public CustomNonCyclicMessageHandler(ILogger<CustomNonCyclicMessageHandler> logger) =>
+            _logger = logger;
+
+        public void Handle(string message, string routingKey, IQueueService queueService)
+        {
+            _logger.LogInformation("Handling messages");
+            var response = new { message, routingKey };
+            queueService.Send(response, "exchange.name", "routing.key");
+        }
+    }
+}

src/Examples.ConsumerHost/Program.cs

@@ -27,7 +27,8 @@ public static async Task Main()
 
                   services.AddRabbitMqClient(rabbitMqSection)
                       .AddExchange("exchange.name", exchangeSection)
-                      .AddMessageHandlerTransient<CustomMessageHandler>("routing.key");
+                      .AddMessageHandlerTransient<CustomMessageHandler>("routing.key")
+                      .AddNonCyclicMessageHandlerSingleton<CustomNonCyclicMessageHandler>("routing.key");
 
                   services.AddSingleton<IHostedService, ConsumingService>();
               });