From 14f18a9e2bf966b2aa59394dc82f620e03d1a193 Mon Sep 17 00:00:00 2001 From: danielmarbach Date: Wed, 13 Mar 2024 17:45:09 +0100 Subject: [PATCH] Disable delayed delivery for ASQ --- src/ServiceControl.Transports.ASQ/ASQTransportCustomization.cs | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/src/ServiceControl.Transports.ASQ/ASQTransportCustomization.cs b/src/ServiceControl.Transports.ASQ/ASQTransportCustomization.cs index 91e1372ca7..1835bbbe62 100644 --- a/src/ServiceControl.Transports.ASQ/ASQTransportCustomization.cs +++ b/src/ServiceControl.Transports.ASQ/ASQTransportCustomization.cs @@ -24,7 +24,7 @@ protected override AzureStorageQueueTransport CreateTransport(TransportSettings { var connectionString = transportSettings.ConnectionString.RemoveCustomConnectionStringParts(out var subscriptionTableName); - var transport = new AzureStorageQueueTransport(connectionString) + var transport = new AzureStorageQueueTransport(connectionString, useNativeDelayedDeliveries: false) { QueueNameSanitizer = BackwardsCompatibleQueueNameSanitizer.Sanitize, MessageInvisibleTime = TimeSpan.FromMinutes(1) @@ -36,7 +36,6 @@ protected override AzureStorageQueueTransport CreateTransport(TransportSettings } transport.MessageWrapperSerializationDefinition = new NewtonsoftJsonSerializer(); - transport.DelayedDelivery.DelayedDeliveryPoisonQueue = transportSettings.ErrorQueue; transport.TransportTransactionMode = transport.GetSupportedTransactionModes().Contains(preferredTransactionMode) ? preferredTransactionMode : TransportTransactionMode.ReceiveOnly;