Merge pull request #4291 from Particular/john/filter

Filter sqs fifo queue at the transport level
Particular · Jul 7, 2024 · 39b230d · 39b230d
2 parents 043ec61 + 383cbc9
commit 39b230d
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/src/Particular.LicensingComponent/Shared/PlatformEndpointHelper.cs b/src/Particular.LicensingComponent/Shared/PlatformEndpointHelper.cs
@@ -11,7 +11,6 @@ public static bool IsPlatformEndpoint(string endpointName, ThroughputSettings th
                 || endpointName.Equals(throughputSettings.ServiceControlQueue, StringComparison.OrdinalIgnoreCase)
                 || endpointName.EndsWith(".Timeouts", StringComparison.OrdinalIgnoreCase)
                 || endpointName.EndsWith(".TimeoutsDispatcher", StringComparison.OrdinalIgnoreCase)
-                || endpointName.EndsWith("-delay.fifo", StringComparison.OrdinalIgnoreCase)
                 || endpointName.StartsWith($"{throughputSettings.ServiceControlQueue}.", StringComparison.OrdinalIgnoreCase)
                 || endpointName.Equals(ServiceControlSettings.ServiceControlThroughputDataQueue, StringComparison.OrdinalIgnoreCase)
                 || AuditThroughputCollectorHostedService.AuditQueues.Any(a => endpointName.Equals(a, StringComparison.OrdinalIgnoreCase));

diff --git a/src/ServiceControl.Transports.SQS/AmazonSQSQuery.cs b/src/ServiceControl.Transports.SQS/AmazonSQSQuery.cs
@@ -243,7 +243,10 @@ public override async IAsyncEnumerable<IBrokerQueue> GetQueueNames(
 
             foreach (var queue in response.QueueUrls.Select(url => url.Split('/')[4]))
             {
-                yield return new DefaultBrokerQueue(queue);
+                if (!queue.EndsWith("-delay.fifo", StringComparison.OrdinalIgnoreCase))
+                {
+                    yield return new DefaultBrokerQueue(queue);
+                }
             }
 
             if (response.NextToken is not null)