testcontainer

Author: coronabytes

Core.TaskProcessor.Tests/Core.TaskProcessor.Tests.csproj

@@ -8,6 +8,7 @@
   <ItemGroup>
     <PackageReference Include="Microsoft.Extensions.DependencyInjection" Version="10.0.0" />
     <PackageReference Include="Microsoft.NET.Test.Sdk" Version="18.0.1" />
+    <PackageReference Include="Testcontainers.Redis" Version="4.10.0" />
     <PackageReference Include="xunit.v3" Version="3.2.2" />
     <PackageReference Include="xunit.v3.extensibility.core" Version="3.2.2" />
     <PackageReference Include="xunit.runner.visualstudio" Version="3.1.5">

Core.TaskProcessor.Tests/ProcessorTests.cs

@@ -1,22 +1,30 @@
 using Newtonsoft.Json;
+using Testcontainers.Redis;
 using Xunit;
 
 namespace Core.TaskProcessor.Tests;
 
-public class ProcessorTests
+public class ProcessorTests : IAsyncLifetime
 {
     private readonly ITestOutputHelper _output;
-    private readonly TaskProcessor _processor;
+    private TaskProcessor _processor = null!;
+    private readonly RedisContainer _redisContainer = new RedisBuilder("valkey/valkey:9-alpine").Build();
 
     public ProcessorTests(ITestOutputHelper output)
     {
         _output = output;
+    }
+
+    public async ValueTask InitializeAsync()
+    {
+        await _redisContainer.StartAsync();
+        
         _processor = new TaskProcessor(new TaskProcessorOptions
         {
             Prefix = "{dev}",
             MaxWorkers = 2,
             Queues = new[] { "q1", "q2[fair]", "q3" },
-            Redis = "localhost:6379,abortConnect=false",
+            Redis = _redisContainer.GetConnectionString() + ",abortConnect=false",
             Retries = 3,
             Deadletter = true,
             OnTaskStart = info =>
@@ -41,6 +49,11 @@ public ProcessorTests(ITestOutputHelper output)
         };
     }
 
+    public async ValueTask DisposeAsync()
+    {
+        await _redisContainer.DisposeAsync();
+    }
+
     [Fact]
     public async Task EnqueueFairness()
     {