fix queue names for Notifications

ppossanzini · Nov 25, 2024 · 7df3426 · 7df3426
1 parent 4e7fd71
commit 7df3426
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git a/Arbitrer.RabbitMQ/Arbitrer.RabbitMQ.csproj b/Arbitrer.RabbitMQ/Arbitrer.RabbitMQ.csproj
@@ -22,10 +22,10 @@
   </PropertyGroup>
   <ItemGroup>
     <PackageReference Include="RabbitMQ.Client" Version="7.0.0" />
-    <PackageReference Include="Newtonsoft.Json" Version="13.*" />
+    <PackageReference Include="Newtonsoft.Json" Version="13.0.3" />
     <PackageReference Include="Microsoft.Extensions.Logging" Version="8.0.0" />
     <PackageReference Include="Microsoft.Extensions.Hosting" Version="8.0.0" />
-    <PackageReference Include="MediatR" Version="12.*" />
+    <PackageReference Include="MediatR" Version="12.4.1" />
   </ItemGroup>
   <ItemGroup>
     <ProjectReference Include="..\Arbitrer\Arbitrer.csproj" />

diff --git a/Arbitrer.RabbitMQ/Extensions/Extensions.cs b/Arbitrer.RabbitMQ/Extensions/Extensions.cs
@@ -65,7 +65,7 @@ public static ArbitrerOptions NotificationsInASingleQueue(this ArbitrerOptions o
 
       foreach (var n in notifications.Where(t => t.IsNotification()))
       {
-        options.SetTypeQueueName(n, $"{n.ArbitrerTypeName(options)}${Assembly.GetEntryAssembly()?.FullName}");
+        options.SetTypeQueueName(n, $"{n.ArbitrerTypeName(options)}${Assembly.GetEntryAssembly()?.GetName().Name.Replace(".","_")}");
       }
 
       return options;

diff --git a/Arbitrer/Arbitrer.csproj b/Arbitrer/Arbitrer.csproj
@@ -27,11 +27,11 @@
     </AssemblyAttribute>
   </ItemGroup>
   <ItemGroup>
-    <PackageReference Include="MediatR" Version="12.*" />
+    <PackageReference Include="MediatR" Version="12.4.1" />
     <PackageReference Include="Microsoft.Extensions.DependencyInjection.Abstractions" Version="8.0.0" />
     <PackageReference Include="Microsoft.Extensions.Hosting.Abstractions" Version="8.0.0" />
     <PackageReference Include="Microsoft.Extensions.Logging.Abstractions" Version="8.0.0" />
     <PackageReference Include="Microsoft.Extensions.Options.ConfigurationExtensions" Version="8.0.0" />
-    <PackageReference Include="Newtonsoft.Json" Version="13.*" />
+    <PackageReference Include="Newtonsoft.Json" Version="13.0.3" />
   </ItemGroup>
 </Project>