From 63ae2ad64912ef3af34da9045e148f85e0a25b41 Mon Sep 17 00:00:00 2001 From: Raymond den Haan Date: Tue, 25 Jun 2024 09:40:53 +0200 Subject: [PATCH] Fix subscription name matching in RemoveOrphanedSubscriptions --- .../Handlers/RemoveOrphanedSubscriptions.cs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/modules/Elsa.MassTransit.AzureServiceBus/Handlers/RemoveOrphanedSubscriptions.cs b/src/modules/Elsa.MassTransit.AzureServiceBus/Handlers/RemoveOrphanedSubscriptions.cs index a95cb6af9..713819638 100644 --- a/src/modules/Elsa.MassTransit.AzureServiceBus/Handlers/RemoveOrphanedSubscriptions.cs +++ b/src/modules/Elsa.MassTransit.AzureServiceBus/Handlers/RemoveOrphanedSubscriptions.cs @@ -33,7 +33,7 @@ public class RemoveOrphanedSubscriptions(MessageTopologyProvider topologyProvide // MassTransit automatically truncates them. await foreach (var asbSubscription in client.GetSubscriptionsAsync(subscription.TopicName, cancellationToken)) { - if (asbSubscription.SubscriptionName.StartsWith($"Elsa-{notification.InstanceName}-")) + if (asbSubscription.SubscriptionName.StartsWith($"{notification.InstanceName}-elsa-")) { var queueName = asbSubscription.ForwardTo[(asbSubscription.ForwardTo.LastIndexOf('/') + 1)..]; @@ -43,7 +43,7 @@ public class RemoveOrphanedSubscriptions(MessageTopologyProvider topologyProvide } } } - catch (ServiceBusException ex) when(ex.Reason == ServiceBusFailureReason.MessagingEntityNotFound) + catch (ServiceBusException ex) when (ex.Reason == ServiceBusFailureReason.MessagingEntityNotFound) { logger.LogWarning(ex, "Service bus entity {entityPath} was not found", ex.EntityPath); }