(#437) identity: update message broker

SaintAngeLs · Oct 27, 2024 · 697f57d · 697f57d
1 parent 7b06984
commit 697f57d
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 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
@@ -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/...iSpace.Services.Identity.Infrastructure/MiniSpace.Services.Identity.Infrastructure.csproj b/...iSpace.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/...ervices.Identity/src/MiniSpace.Services.Identity.Infrastructure/Services/MessageBroker.cs b/...ervices.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,
             }
         }
     }
-}
+}