Class ErrorPolicyBuilderMoveToKafkaTopicExtensions

Adds the MoveToKafkaTopic method to the IErrorPolicyBuilder.

Inheritance

System.Object

ErrorPolicyBuilderMoveToKafkaTopicExtensions

Inherited Members

System.Object.Equals(System.Object)

System.Object.Equals(System.Object, System.Object)

System.Object.GetHashCode()

System.Object.GetType()

System.Object.MemberwiseClone()

System.Object.ReferenceEquals(System.Object, System.Object)

System.Object.ToString()

Namespace: Silverback.Messaging.Configuration

Assembly: Silverback.Integration.Kafka.dll

Syntax

public static class ErrorPolicyBuilderMoveToKafkaTopicExtensions

Methods

MoveToKafkaTopic(IErrorPolicyBuilder, Action<IKafkaProducerEndpointBuilder>, Action<MoveMessageErrorPolicy>)

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

Declaration

public static IErrorPolicyChainBuilder MoveToKafkaTopic(this IErrorPolicyBuilder builder, Action<IKafkaProducerEndpointBuilder> endpointBuilderAction, Action<MoveMessageErrorPolicy> policyConfigurationAction = null)

Parameters

Type	Name	Description
IErrorPolicyBuilder	builder	The IErrorPolicyBuilder.
System.Action<IKafkaProducerEndpointBuilder>	endpointBuilderAction	An System.Action<T> that takes the IKafkaProducerEndpointBuilder and configures it.
System.Action<MoveMessageErrorPolicy>	policyConfigurationAction	The (optional) additional configuration.

Returns

Type	Description
IErrorPolicyChainBuilder	The IErrorPolicyChainBuilder so that additional calls can be chained.