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;