ASQ transport has a native delayed delivery feature that in case of failure in dispatching the delayed message moves it to the error queue. For historical reasons, the transport used to detect the endpoint configured error queue and use that as the delayed delivery error queue. With the new transport seam and the ability to use transports in raw mode without an NServiceBus endpoint the following hack is needed:
|
var nativeDelayedDeliveryErrorQueue = DelayedDelivery.DelayedDeliveryPoisonQueue |
|
?? hostSettings.CoreSettings?.GetOrDefault<string>(ErrorQueueSettings.SettingsKey) |
|
?? receiversSettings.Select(settings => settings.ErrorQueue).FirstOrDefault(); |
ASQ transport has a native delayed delivery feature that in case of failure in dispatching the delayed message moves it to the error queue. For historical reasons, the transport used to detect the endpoint configured error queue and use that as the delayed delivery error queue. With the new transport seam and the ability to use transports in raw mode without an NServiceBus endpoint the following hack is needed:
NServiceBus.AzureStorageQueues/src/Transport/AzureStorageQueueTransport.cs
Lines 154 to 156 in 35e4cb2