From 7df3426b88736826eb4b9730be28f2fa7abccc2b Mon Sep 17 00:00:00 2001 From: Paolo Possanzini Date: Mon, 25 Nov 2024 17:23:28 +0100 Subject: [PATCH] fix queue names for Notifications --- Arbitrer.RabbitMQ/Arbitrer.RabbitMQ.csproj | 4 ++-- Arbitrer.RabbitMQ/Extensions/Extensions.cs | 2 +- Arbitrer/Arbitrer.csproj | 4 ++-- 3 files changed, 5 insertions(+), 5 deletions(-) diff --git a/Arbitrer.RabbitMQ/Arbitrer.RabbitMQ.csproj b/Arbitrer.RabbitMQ/Arbitrer.RabbitMQ.csproj index 065ce35..0b39e39 100644 --- a/Arbitrer.RabbitMQ/Arbitrer.RabbitMQ.csproj +++ b/Arbitrer.RabbitMQ/Arbitrer.RabbitMQ.csproj @@ -22,10 +22,10 @@ - + - + diff --git a/Arbitrer.RabbitMQ/Extensions/Extensions.cs b/Arbitrer.RabbitMQ/Extensions/Extensions.cs index 65b9d9e..4be73d0 100644 --- 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 index d450a6e..f619cc6 100644 --- a/Arbitrer/Arbitrer.csproj +++ b/Arbitrer/Arbitrer.csproj @@ -27,11 +27,11 @@ - + - + \ No newline at end of file