Made a first integration test

Anton Vorontsov · Anton Vorontsov · commit 1985af80042b · 2020-05-13T02:28:07.000+03:00
diff --git a/tests/RabbitMQ.Client.Core.DependencyInjection.Tests/IntegrationTests/QueueServiceTests.cs b/tests/RabbitMQ.Client.Core.DependencyInjection.Tests/IntegrationTests/QueueServiceTests.cs
@@ -0,0 +1,55 @@
+using System.Collections.Generic;
+using System.Threading.Tasks;
+using Microsoft.Extensions.DependencyInjection;
+using Moq;
+using RabbitMQ.Client.Core.DependencyInjection.Configuration;
+using RabbitMQ.Client.Core.DependencyInjection.Services;
+using RabbitMQ.Client.Core.DependencyInjection.Tests.Stubs;
+using Xunit;
+
+namespace RabbitMQ.Client.Core.DependencyInjection.Tests.IntegrationTests
+{
+    public class QueueServiceTests
+    {
+        [Fact]
+        public async Task ShouldProperlyPublishAndConsumeMessages()
+        {
+            var clientOptions = new RabbitMqClientOptions
+            {
+                HostName = "localhost",
+                Port = 5672,
+                UserName = "guest",
+                Password = "guest",
+                VirtualHost = "/"
+            };
+            
+            var exchangeOptions = new RabbitMqExchangeOptions
+            {
+                Type = "direct",
+                DeadLetterExchange = "exchange.dlx",
+                Queues = new List<RabbitMqQueueOptions>
+                {
+                    new RabbitMqQueueOptions
+                    {
+                        Name = "test.queue",
+                        RoutingKeys = new HashSet<string> { "routing.key" }
+                    }
+                }
+            };
+            var serviceCollection = new ServiceCollection();
+
+            var callerMock = new Mock<IStubCaller>();
+            serviceCollection.AddRabbitMqClient(clientOptions)
+                .AddConsumptionExchange("exchange.name", exchangeOptions)
+                .AddMessageHandlerTransient<StubMessageHandler>("routing.key")
+                .AddSingleton(callerMock.Object);
+            
+            var serviceProvider = serviceCollection.BuildServiceProvider();
+
+            var queueService = serviceProvider.GetRequiredService<IQueueService>();
+            queueService.StartConsuming();
+
+            await queueService.SendAsync("message", "exchange.name", "routing.key");
+        }
+    }
+}
diff --git a/tests/RabbitMQ.Client.Core.DependencyInjection.Tests/Stubs/IStubCaller.cs b/tests/RabbitMQ.Client.Core.DependencyInjection.Tests/Stubs/IStubCaller.cs
@@ -1,6 +1,6 @@
 using System;
 
-namespace RabbitMQ.Client.Core.DependencyInjection.Tests.UnitTests.Stubs
+namespace RabbitMQ.Client.Core.DependencyInjection.Tests.Stubs
 {
     public interface IStubCaller
     {
diff --git a/tests/RabbitMQ.Client.Core.DependencyInjection.Tests/Stubs/StubAsyncMessageHandler.cs b/tests/RabbitMQ.Client.Core.DependencyInjection.Tests/Stubs/StubAsyncMessageHandler.cs
@@ -2,9 +2,9 @@
 using System.Threading.Tasks;
 using RabbitMQ.Client.Core.DependencyInjection.MessageHandlers;
 
-namespace RabbitMQ.Client.Core.DependencyInjection.Tests.UnitTests.Stubs
+namespace RabbitMQ.Client.Core.DependencyInjection.Tests.Stubs
 {
-    internal class StubAsyncMessageHandler : IAsyncMessageHandler
+    public class StubAsyncMessageHandler : IAsyncMessageHandler
     {
         public Task Handle(string message, string routingKey)
         {
diff --git a/tests/RabbitMQ.Client.Core.DependencyInjection.Tests/Stubs/StubAsyncNonCyclicMessageHandler.cs b/tests/RabbitMQ.Client.Core.DependencyInjection.Tests/Stubs/StubAsyncNonCyclicMessageHandler.cs
@@ -3,9 +3,9 @@
 using RabbitMQ.Client.Core.DependencyInjection.MessageHandlers;
 using RabbitMQ.Client.Core.DependencyInjection.Services;
 
-namespace RabbitMQ.Client.Core.DependencyInjection.Tests.UnitTests.Stubs
+namespace RabbitMQ.Client.Core.DependencyInjection.Tests.Stubs
 {
-    internal class StubAsyncNonCyclicMessageHandler : IAsyncNonCyclicMessageHandler
+    public class StubAsyncNonCyclicMessageHandler : IAsyncNonCyclicMessageHandler
     {
         public Task Handle(string message, string routingKey, IQueueService queueService)
         {
diff --git a/tests/RabbitMQ.Client.Core.DependencyInjection.Tests/Stubs/StubBaseBatchMessageHandler.cs b/tests/RabbitMQ.Client.Core.DependencyInjection.Tests/Stubs/StubBaseBatchMessageHandler.cs
@@ -7,7 +7,7 @@
 using RabbitMQ.Client.Core.DependencyInjection.Models;
 using RabbitMQ.Client.Core.DependencyInjection.Services;
 
-namespace RabbitMQ.Client.Core.DependencyInjection.Tests.UnitTests.Stubs
+namespace RabbitMQ.Client.Core.DependencyInjection.Tests.Stubs
 {
     public class StubBaseBatchMessageHandler : BaseBatchMessageHandler
     {
diff --git a/tests/RabbitMQ.Client.Core.DependencyInjection.Tests/Stubs/StubBatchMessageHandler.cs b/tests/RabbitMQ.Client.Core.DependencyInjection.Tests/Stubs/StubBatchMessageHandler.cs
@@ -6,7 +6,7 @@
 using RabbitMQ.Client.Core.DependencyInjection.Models;
 using RabbitMQ.Client.Core.DependencyInjection.Services;
 
-namespace RabbitMQ.Client.Core.DependencyInjection.Tests.UnitTests.Stubs
+namespace RabbitMQ.Client.Core.DependencyInjection.Tests.Stubs
 {
     public class StubBatchMessageHandler : BatchMessageHandler
     {
diff --git a/tests/RabbitMQ.Client.Core.DependencyInjection.Tests/Stubs/StubMessageHandler.cs b/tests/RabbitMQ.Client.Core.DependencyInjection.Tests/Stubs/StubMessageHandler.cs
@@ -0,0 +1,19 @@
+using RabbitMQ.Client.Core.DependencyInjection.MessageHandlers;
+
+namespace RabbitMQ.Client.Core.DependencyInjection.Tests.Stubs
+{
+    public class StubMessageHandler : IMessageHandler
+    {
+        readonly IStubCaller _caller;
+        
+        public StubMessageHandler(IStubCaller caller)
+        {
+            _caller = caller;
+        }
+
+        public void Handle(string message, string routingKey)
+        {
+            _caller.Call($"{message}:{routingKey}");
+        }
+    }
+}
diff --git a/tests/RabbitMQ.Client.Core.DependencyInjection.Tests/Stubs/StubNonCyclicMessageHandler.cs b/tests/RabbitMQ.Client.Core.DependencyInjection.Tests/Stubs/StubNonCyclicMessageHandler.cs
@@ -2,9 +2,9 @@
 using RabbitMQ.Client.Core.DependencyInjection.MessageHandlers;
 using RabbitMQ.Client.Core.DependencyInjection.Services;
 
-namespace RabbitMQ.Client.Core.DependencyInjection.Tests.UnitTests.Stubs
+namespace RabbitMQ.Client.Core.DependencyInjection.Tests.Stubs
 {
-    internal class StubNonCyclicMessageHandler : INonCyclicMessageHandler
+    public class StubNonCyclicMessageHandler : INonCyclicMessageHandler
     {
         public void Handle(string message, string routingKey, IQueueService queueService)
         {
diff --git a/tests/RabbitMQ.Client.Core.DependencyInjection.Tests/UnitTests/BaseBatchMessageHandlerTests.cs b/tests/RabbitMQ.Client.Core.DependencyInjection.Tests/UnitTests/BaseBatchMessageHandlerTests.cs
@@ -8,7 +8,7 @@
 using RabbitMQ.Client.Core.DependencyInjection.Configuration;
 using RabbitMQ.Client.Core.DependencyInjection.Models;
 using RabbitMQ.Client.Core.DependencyInjection.Services;
-using RabbitMQ.Client.Core.DependencyInjection.Tests.UnitTests.Stubs;
+using RabbitMQ.Client.Core.DependencyInjection.Tests.Stubs;
 using RabbitMQ.Client.Events;
 using Xunit;
 
diff --git a/tests/RabbitMQ.Client.Core.DependencyInjection.Tests/UnitTests/BatchMessageHandlerDependencyInjectionExtensionsTests.cs b/tests/RabbitMQ.Client.Core.DependencyInjection.Tests/UnitTests/BatchMessageHandlerDependencyInjectionExtensionsTests.cs
@@ -4,7 +4,7 @@
 using Moq;
 using RabbitMQ.Client.Core.DependencyInjection.Configuration;
 using RabbitMQ.Client.Core.DependencyInjection.Exceptions;
-using RabbitMQ.Client.Core.DependencyInjection.Tests.UnitTests.Stubs;
+using RabbitMQ.Client.Core.DependencyInjection.Tests.Stubs;
 using Xunit;
 
 namespace RabbitMQ.Client.Core.DependencyInjection.Tests.UnitTests
diff --git a/tests/RabbitMQ.Client.Core.DependencyInjection.Tests/UnitTests/BatchMessageHandlerTests.cs b/tests/RabbitMQ.Client.Core.DependencyInjection.Tests/UnitTests/BatchMessageHandlerTests.cs
@@ -8,7 +8,7 @@
 using RabbitMQ.Client.Core.DependencyInjection.Configuration;
 using RabbitMQ.Client.Core.DependencyInjection.Models;
 using RabbitMQ.Client.Core.DependencyInjection.Services;
-using RabbitMQ.Client.Core.DependencyInjection.Tests.UnitTests.Stubs;
+using RabbitMQ.Client.Core.DependencyInjection.Tests.Stubs;
 using RabbitMQ.Client.Events;
 using Xunit;
 
diff --git a/tests/RabbitMQ.Client.Core.DependencyInjection.Tests/UnitTests/MessageHandlerDependencyInjectionExtensionsTests.cs b/tests/RabbitMQ.Client.Core.DependencyInjection.Tests/UnitTests/MessageHandlerDependencyInjectionExtensionsTests.cs
@@ -1,7 +1,7 @@
 using System;
 using System.Threading.Tasks;
 using Microsoft.Extensions.DependencyInjection;
-using RabbitMQ.Client.Core.DependencyInjection.Tests.UnitTests.Stubs;
+using RabbitMQ.Client.Core.DependencyInjection.Tests.Stubs;
 using Xunit;
 
 namespace RabbitMQ.Client.Core.DependencyInjection.Tests.UnitTests
diff --git a/tests/RabbitMQ.Client.Core.DependencyInjection.Tests/UnitTests/Stubs/StubMessageHandler.cs b/tests/RabbitMQ.Client.Core.DependencyInjection.Tests/UnitTests/Stubs/StubMessageHandler.cs

Original file line number	Diff line number	Diff line change
`@@ -1,6 +1,6 @@`
`1`	`1`	`using System;`
`2`	`2`
`3`		`-namespace RabbitMQ.Client.Core.DependencyInjection.Tests.UnitTests.Stubs`
	`3`	`+namespace RabbitMQ.Client.Core.DependencyInjection.Tests.Stubs`
`4`	`4`	`{`
`5`	`5`	`public interface IStubCaller`
`6`	`6`	`{`
Original file line number	Diff line number	Diff line change
`@@ -2,9 +2,9 @@`
`2`	`2`	`using System.Threading.Tasks;`
`3`	`3`	`using RabbitMQ.Client.Core.DependencyInjection.MessageHandlers;`
`4`	`4`
`5`		`-namespace RabbitMQ.Client.Core.DependencyInjection.Tests.UnitTests.Stubs`
	`5`	`+namespace RabbitMQ.Client.Core.DependencyInjection.Tests.Stubs`
`6`	`6`	`{`
`7`		`- internal class StubAsyncMessageHandler : IAsyncMessageHandler`
	`7`	`+ public class StubAsyncMessageHandler : IAsyncMessageHandler`
`8`	`8`	`{`
`9`	`9`	`public Task Handle(string message, string routingKey)`
`10`	`10`	`{`
Original file line number	Diff line number	Diff line change
`@@ -3,9 +3,9 @@`
`3`	`3`	`using RabbitMQ.Client.Core.DependencyInjection.MessageHandlers;`
`4`	`4`	`using RabbitMQ.Client.Core.DependencyInjection.Services;`
`5`	`5`
`6`		`-namespace RabbitMQ.Client.Core.DependencyInjection.Tests.UnitTests.Stubs`
	`6`	`+namespace RabbitMQ.Client.Core.DependencyInjection.Tests.Stubs`
`7`	`7`	`{`
`8`		`- internal class StubAsyncNonCyclicMessageHandler : IAsyncNonCyclicMessageHandler`
	`8`	`+ public class StubAsyncNonCyclicMessageHandler : IAsyncNonCyclicMessageHandler`
`9`	`9`	`{`
`10`	`10`	`public Task Handle(string message, string routingKey, IQueueService queueService)`
`11`	`11`	`{`
Original file line number	Diff line number	Diff line change
`@@ -7,7 +7,7 @@`
`7`	`7`	`using RabbitMQ.Client.Core.DependencyInjection.Models;`
`8`	`8`	`using RabbitMQ.Client.Core.DependencyInjection.Services;`
`9`	`9`
`10`		`-namespace RabbitMQ.Client.Core.DependencyInjection.Tests.UnitTests.Stubs`
	`10`	`+namespace RabbitMQ.Client.Core.DependencyInjection.Tests.Stubs`
`11`	`11`	`{`
`12`	`12`	`public class StubBaseBatchMessageHandler : BaseBatchMessageHandler`
`13`	`13`	`{`
Original file line number	Diff line number	Diff line change
`@@ -6,7 +6,7 @@`
`6`	`6`	`using RabbitMQ.Client.Core.DependencyInjection.Models;`
`7`	`7`	`using RabbitMQ.Client.Core.DependencyInjection.Services;`
`8`	`8`
`9`		`-namespace RabbitMQ.Client.Core.DependencyInjection.Tests.UnitTests.Stubs`
	`9`	`+namespace RabbitMQ.Client.Core.DependencyInjection.Tests.Stubs`
`10`	`10`	`{`
`11`	`11`	`public class StubBatchMessageHandler : BatchMessageHandler`
`12`	`12`	`{`