From 697f57dcaa5a9a7376337d9f16c45e20f0eeefa1 Mon Sep 17 00:00:00 2001
From: Andrii Voznesenskyi <voznesenskijandrej5@gmail.com>
Date: Sun, 27 Oct 2024 18:34:00 +0100
Subject: [PATCH] (#437) identity: update message broker

---
 .../MiniSpace.Services.Identity.Infrastructure/Extensions.cs | 1 +
 .../MiniSpace.Services.Identity.Infrastructure.csproj        | 5 +++++
 .../Services/MessageBroker.cs                                | 5 +----
 3 files changed, 7 insertions(+), 4 deletions(-)

diff --git a/MiniSpace.Services.Identity/src/MiniSpace.Services.Identity.Infrastructure/Extensions.cs b/MiniSpace.Services.Identity/src/MiniSpace.Services.Identity.Infrastructure/Extensions.cs
index e387a036c..e4af75c15 100644
--- a/MiniSpace.Services.Identity/src/MiniSpace.Services.Identity.Infrastructure/Extensions.cs
+++ b/MiniSpace.Services.Identity/src/MiniSpace.Services.Identity.Infrastructure/Extensions.cs
@@ -91,6 +91,7 @@ public static IParalaxBuilder AddInfrastructure(this IParalaxBuilder builder)
                 .AddConsul()
                 .AddFabio()
                 .AddExceptionToMessageMapper<ExceptionToMessageMapper>()
+                .AddRabbitMq()
                 .AddRabbitMq(plugins: p => p.AddJaegerRabbitMqPlugin())
                 .AddMessageOutbox(o => o.AddMongo())
                 .AddMongo()
diff --git a/MiniSpace.Services.Identity/src/MiniSpace.Services.Identity.Infrastructure/MiniSpace.Services.Identity.Infrastructure.csproj b/MiniSpace.Services.Identity/src/MiniSpace.Services.Identity.Infrastructure/MiniSpace.Services.Identity.Infrastructure.csproj
index eaccd5559..ae77f86b2 100644
--- a/MiniSpace.Services.Identity/src/MiniSpace.Services.Identity.Infrastructure/MiniSpace.Services.Identity.Infrastructure.csproj
+++ b/MiniSpace.Services.Identity/src/MiniSpace.Services.Identity.Infrastructure/MiniSpace.Services.Identity.Infrastructure.csproj
@@ -67,4 +67,9 @@
         <ProjectReference Include="..\MiniSpace.Services.Identity.Application\MiniSpace.Services.Identity.Application.csproj" />
     </ItemGroup>
 
+    <!-- <ItemGroup>
+        <ProjectReference Include="../../../Paralax/src/Paralax.MessageBrokers.RabbitMQ/src/Paralax.MessageBrokers.RabbitMQ/Paralax.MessageBrokers.RabbitMQ.csproj" />
+        <ProjectReference Include="../../../Paralax/src/Paralax.MessageBrokers/src/Paralax.MessageBrokers/Paralax.MessageBrokers.csproj" />
+    </ItemGroup> -->
+
 </Project>
diff --git a/MiniSpace.Services.Identity/src/MiniSpace.Services.Identity.Infrastructure/Services/MessageBroker.cs b/MiniSpace.Services.Identity/src/MiniSpace.Services.Identity.Infrastructure/Services/MessageBroker.cs
index 023a8e301..6c2149e53 100644
--- a/MiniSpace.Services.Identity/src/MiniSpace.Services.Identity.Infrastructure/Services/MessageBroker.cs
+++ b/MiniSpace.Services.Identity/src/MiniSpace.Services.Identity.Infrastructure/Services/MessageBroker.cs
@@ -1,7 +1,6 @@
 using System;
 using System.Collections.Generic;
 using System.Linq;
-using System.Runtime.CompilerServices;
 using System.Threading.Tasks;
 using Paralax.CQRS.Events;
 using Paralax.MessageBrokers;
@@ -11,9 +10,7 @@
 using Microsoft.Extensions.Logging;
 using OpenTracing;
 using MiniSpace.Services.Identity.Application.Services;
-using System.Diagnostics.CodeAnalysis;
 
-[assembly: InternalsVisibleTo("MiniSpace.Services.Identity.Infrastructure.UnitTests")]
 namespace MiniSpace.Services.Identity.Infrastructure.Services
 {
     internal sealed class MessageBroker : IMessageBroker
@@ -88,4 +85,4 @@ await _busPublisher.PublishAsync(@event, messageId, correlationId, spanContext,
             }
         }
     }
-}
\ No newline at end of file
+}