Delayed retries cannot be used when transport transactions are disabled or delayed delivery is not available. For more information about transport transactions, refer to transport transactions. For more details on delayed delivery, see the delayed delivery article.
Configuring delayed retries
TimeIncrease: Specifies the delay interval for each retry attempt. This delay increases by the same timespan with each delayed delivery. The default value is 10 seconds. For example, with the default value of 10 seconds, i.e., 00:00:10, the first delayed retry will occur at 10 seconds, the subsequent delayed retry will occur at 20 seconds, and so on.NumberOfRetries: Number of times delayed retries are performed. Default is 3.
var recoverability = endpointConfiguration.Recoverability();
recoverability.Delayed(
delayed =>
{
delayed.NumberOfRetries(2);
delayed.TimeIncrease(TimeSpan.FromMinutes(5));
});
Disabling through code
var recoverability = endpointConfiguration.Recoverability();
recoverability.Delayed(
delayed =>
{
delayed.NumberOfRetries(0);
});
Custom retry policy
Custom retry logic can be configured via code.
var recoverability = endpointConfiguration.Recoverability();
recoverability.CustomPolicy(MyCustomRetryPolicy);
More details can be found in the recoverability policy documentation.
Simple policy
The following retry policy overrides the default ten second delay interval and sets it to five seconds.
RecoverabilityAction MyCustomRetryPolicy(RecoverabilityConfig config, ErrorContext context)
{
var action = DefaultRecoverabilityPolicy.Invoke(config, context);
if (!(action is DelayedRetry delayedRetryAction))
{
return action;
}
// Override default delivery delay.
return RecoverabilityAction.DelayedRetry(TimeSpan.FromSeconds(5));
}
Exception-based policy
Sometimes the number of retries or the delay interval might depend on the error exception thrown. The following retry policy extends the previous one by skipping delayed retries whenever MyBusinessException has been thrown during incoming message processing.
RecoverabilityAction MyCustomRetryPolicy(RecoverabilityConfig config, ErrorContext context)
{
var action = DefaultRecoverabilityPolicy.Invoke(config, context);
if (!(action is DelayedRetry delayedRetryAction))
{
return action;
}
if (context.Exception is MyBusinessException)
{
return RecoverabilityAction.MoveToError(config.Failed.ErrorQueue);
}
// Override default delivery delay.
return RecoverabilityAction.DelayedRetry(TimeSpan.FromSeconds(5));
}