Interface IErrorPolicyBuilder

Builds the IErrorPolicy.

Namespace: Silverback.Messaging.Configuration

Assembly: Silverback.Integration.dll

Syntax

public interface IErrorPolicyBuilder

Methods

Move(IProducerEndpoint, Action<MoveMessageErrorPolicy>?)

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

Declaration

IErrorPolicyChainBuilder Move(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.

Retry(Action<RetryErrorPolicy>)

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

Declaration

IErrorPolicyChainBuilder Retry(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.

Retry(int, Action<RetryErrorPolicy>)

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

Declaration

IErrorPolicyChainBuilder Retry(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.

Retry(int, TimeSpan, Action<RetryErrorPolicy>)

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

Declaration

IErrorPolicyChainBuilder Retry(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.

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

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

Declaration

IErrorPolicyChainBuilder Retry(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.

Skip(Action<SkipMessageErrorPolicy>?)

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

Declaration

IErrorPolicyChainBuilder Skip(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.

Stop(Action<StopConsumerErrorPolicy>?)

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

Declaration

IErrorPolicyChainBuilder Stop(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

ErrorPolicyBuilderMoveToKafkaTopicExtensions.MoveToKafkaTopic(IErrorPolicyBuilder, Action<IKafkaProducerEndpointBuilder>, Action<MoveMessageErrorPolicy>?)

ErrorPolicyBuilderMoveToMqttTopicExtensions.MoveToMqttTopic(IErrorPolicyBuilder, Action<IMqttProducerEndpointBuilder>, Action<MoveMessageErrorPolicy>?)