Class ErrorPolicyChainBuilderMoveToMqttTopicExtensions
Adds the ThenMoveToMqttTopic
method to the IErrorPolicyChainBuilder.
Inheritance
System.Object
ErrorPolicyChainBuilderMoveToMqttTopicExtensions
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.MQTT.dll
Syntax
public static class ErrorPolicyChainBuilderMoveToMqttTopicExtensions
Methods
| Improve this doc View sourceThenMoveToMqttTopic(IErrorPolicyChainBuilder, Action<IMqttProducerEndpointBuilder>, Action<MoveMessageErrorPolicy>)
Adds a MoveMessageErrorPolicy that moves the messages that fail to be processed to the configured endpoint.
Declaration
public static IErrorPolicyChainBuilder ThenMoveToMqttTopic(this IErrorPolicyChainBuilder builder, Action<IMqttProducerEndpointBuilder> endpointBuilderAction, Action<MoveMessageErrorPolicy> policyConfigurationAction = null)
Parameters
Type | Name | Description |
---|---|---|
IErrorPolicyChainBuilder | builder | |
System.Action<IMqttProducerEndpointBuilder> | endpointBuilderAction | An System.Action<T> that takes the IMqttProducerEndpointBuilder and configures it. |
System.Action<MoveMessageErrorPolicy> | policyConfigurationAction | The (optional) additional configuration. |
Returns
Type | Description |
---|---|
IErrorPolicyChainBuilder | The IErrorPolicyChainBuilder so that additional calls can be chained. |