fix: Create Connection for rabbit health check

alex289 · Jan 1, 2025 · 255dbb3 · 255dbb3
1 parent 133c868
commit 255dbb3
Showing 1 changed file with 10 additions and 1 deletion.
diff --git a/CleanArchitecture.Api/Program.cs b/CleanArchitecture.Api/Program.cs
@@ -1,3 +1,4 @@
+using System;
 using CleanArchitecture.Api.BackgroundServices;
 using CleanArchitecture.Api.Extensions;
 using CleanArchitecture.Application.Extensions;
@@ -15,6 +16,7 @@
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Hosting;
 using Microsoft.Extensions.Logging;
+using RabbitMQ.Client;
 
 var builder = WebApplication.CreateBuilder(args);
 
@@ -46,7 +48,14 @@
         .AddSqlServer(dbConnectionString!)
         .AddRedis(redisConnectionString!, "Redis")
         .AddRabbitMQ(
-            rabbitConfiguration.ConnectionString,
+            async _ =>
+            {
+                var factory = new ConnectionFactory
+                {
+                    Uri = new Uri(rabbitConfiguration.ConnectionString),
+                };
+                return await factory.CreateConnectionAsync();
+            },
             name: "RabbitMQ");
 }