Interface IErrorPolicyChainBuilder

Builds the IErrorPolicy.

Namespace: Silverback.Messaging.Configuration
Assembly: Silverback.Integration.dll
Syntax
public interface IErrorPolicyChainBuilder

Methods

| Improve this doc View source

ThenMove(IProducerEndpoint, Action<MoveMessageErrorPolicy>?)

Adds a MoveMessageErrorPolicy that moves the messages that fail to be processed to the configured endpoint.

Declaration
IErrorPolicyChainBuilder ThenMove(IProducerEndpoint endpoint, Action<MoveMessageErrorPolicy>? policyConfigurationAction = null)
Parameters
Type Name Description
IProducerEndpoint endpoint

The endpoint to move the message to.
Action<MoveMessageErrorPolicy> policyConfigurationAction

The (optional) additional configuration.
Returns
Type Description
IErrorPolicyChainBuilder

The IErrorPolicyChainBuilder so that additional calls can be chained.
| Improve this doc View source

ThenRetry(Action<RetryErrorPolicy>)

Adds a RetryErrorPolicy that retries to process the messages that previously failed to be to processed.

Declaration
IErrorPolicyChainBuilder ThenRetry(Action<RetryErrorPolicy> policyConfigurationAction)
Parameters
Type Name Description
Action<RetryErrorPolicy> policyConfigurationAction

The (optional) additional configuration.
Returns
Type Description
IErrorPolicyChainBuilder

The IErrorPolicyChainBuilder so that additional calls can be chained.
| Improve this doc View source

ThenRetry(int, Action<RetryErrorPolicy>)

Adds a RetryErrorPolicy that retries to process the messages that previously failed to be to processed.

Declaration
IErrorPolicyChainBuilder ThenRetry(int retriesCount, Action<RetryErrorPolicy> policyConfigurationAction)
Parameters
Type Name Description
int retriesCount

The maximum number of retries to be performed.
Action<RetryErrorPolicy> policyConfigurationAction

The (optional) additional configuration.
Returns
Type Description
IErrorPolicyChainBuilder

The IErrorPolicyChainBuilder so that additional calls can be chained.
| Improve this doc View source

ThenRetry(int, TimeSpan, Action<RetryErrorPolicy>)

Adds a RetryErrorPolicy that retries to process the messages that previously failed to be to processed.

Declaration
IErrorPolicyChainBuilder ThenRetry(int retriesCount, TimeSpan initialDelay, Action<RetryErrorPolicy> policyConfigurationAction)
Parameters
Type Name Description
int retriesCount

The maximum number of retries to be performed.
TimeSpan initialDelay

The optional delay to be applied to the first retry.
Action<RetryErrorPolicy> policyConfigurationAction

The (optional) additional configuration.
Returns
Type Description
IErrorPolicyChainBuilder

The IErrorPolicyChainBuilder so that additional calls can be chained.
| Improve this doc View source

ThenRetry(int?, TimeSpan?, TimeSpan?, Action<RetryErrorPolicy>?)

Adds a RetryErrorPolicy that retries to process the messages that previously failed to be to processed.

Declaration
IErrorPolicyChainBuilder ThenRetry(int? retriesCount = null, TimeSpan? initialDelay = null, TimeSpan? delayIncrement = null, Action<RetryErrorPolicy>? policyConfigurationAction = null)
Parameters
Type Name Description
int? retriesCount

The maximum number of retries to be performed.
TimeSpan? initialDelay

The optional delay to be applied to the first retry.
TimeSpan? delayIncrement

The optional increment to the delay to be applied at each retry.
Action<RetryErrorPolicy> policyConfigurationAction

The (optional) additional configuration.
Returns
Type Description
IErrorPolicyChainBuilder

The IErrorPolicyChainBuilder so that additional calls can be chained.
| Improve this doc View source

ThenSkip(Action<SkipMessageErrorPolicy>?)

Adds a SkipMessageErrorPolicy that skips the messages that fail to be processed.

Declaration
IErrorPolicyChainBuilder ThenSkip(Action<SkipMessageErrorPolicy>? policyConfigurationAction = null)
Parameters
Type Name Description
Action<SkipMessageErrorPolicy> policyConfigurationAction

The (optional) additional configuration.
Returns
Type Description
IErrorPolicyChainBuilder

The IErrorPolicyChainBuilder so that additional calls can be chained.
| Improve this doc View source

ThenStop(Action<StopConsumerErrorPolicy>?)

Adds a StopConsumerErrorPolicy that stops the consumer when an exception is thrown during the message processing.

Declaration
IErrorPolicyChainBuilder ThenStop(Action<StopConsumerErrorPolicy>? policyConfigurationAction = null)
Parameters
Type Name Description
Action<StopConsumerErrorPolicy> policyConfigurationAction

The (optional) additional configuration.
Returns
Type Description
IErrorPolicyChainBuilder

The IErrorPolicyChainBuilder so that additional calls can be chained.

Extension Methods