Class ErrorPolicyBuilder

Builds the IErrorPolicy.

Inheritance

object

ErrorPolicyBuilder

Implements

IErrorPolicyBuilder

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: Silverback.Messaging.Configuration

Assembly: Silverback.Integration.dll

Syntax

public class ErrorPolicyBuilder : IErrorPolicyBuilder

Constructors

ErrorPolicyBuilder(IEndpointsConfigurationBuilder?)

Initializes a new instance of the ErrorPolicyBuilder class.

Declaration

public ErrorPolicyBuilder(IEndpointsConfigurationBuilder? endpointsConfigurationBuilder = null)

Parameters

Type	Name	Description
IEndpointsConfigurationBuilder	endpointsConfigurationBuilder	The optional reference to the IEndpointsConfigurationBuilder that instantiated the builder.

Properties

EndpointsConfigurationBuilder

Gets the IEndpointsConfigurationBuilder that instantiated the builder.

Declaration

public IEndpointsConfigurationBuilder? EndpointsConfigurationBuilder { get; }

Property Value

Type	Description
IEndpointsConfigurationBuilder

Methods

Build()

Builds the IErrorPolicy instance.

Declaration

public IErrorPolicy Build()

Returns

Type	Description
IErrorPolicy	The IMessageSerializer.

Move(IProducerEndpoint, Action<MoveMessageErrorPolicy>?)

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

Declaration

public 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

public 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

public 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

public 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

public 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

public 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

public 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.

Implements

IErrorPolicyBuilder

Extension Methods

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

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