Class MqttOutboundEndpointRouter<TMessage>

Routes the outbound messages to one or multiple MQTT endpoints.

Inheritance

object

OutboundRouter<TMessage>

DictionaryOutboundRouter<TMessage, MqttProducerEndpoint>

MqttOutboundEndpointRouter<TMessage>

Implements

IOutboundRouter<TMessage>

IOutboundRouter

Inherited Members

DictionaryOutboundRouter<TMessage, MqttProducerEndpoint>.Endpoints

DictionaryOutboundRouter<TMessage, MqttProducerEndpoint>.GetDestinationEndpoints(TMessage, MessageHeaderCollection)

OutboundRouter<TMessage>.Endpoints

OutboundRouter<TMessage>.GetDestinationEndpoints(TMessage, MessageHeaderCollection)

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: Silverback.Messaging.Outbound.Routing

Assembly: Silverback.Integration.MQTT.dll

Syntax

public class MqttOutboundEndpointRouter<TMessage> : DictionaryOutboundRouter<TMessage, MqttProducerEndpoint>, IOutboundRouter<TMessage>, IOutboundRouter

Type Parameters

Name	Description
TMessage	The type of the messages to be routed.

Constructors

MqttOutboundEndpointRouter(RouterFunction, IReadOnlyDictionary<string, Action<IMqttProducerEndpointBuilder>>, MqttClientConfig)

Initializes a new instance of the MqttOutboundEndpointRouter<TMessage> class.

Declaration

public MqttOutboundEndpointRouter(DictionaryOutboundRouter<TMessage, MqttProducerEndpoint>.RouterFunction routerFunction, IReadOnlyDictionary<string, Action<IMqttProducerEndpointBuilder>> endpointBuilderActions, MqttClientConfig clientConfig)

Parameters

Type	Name	Description
DictionaryOutboundRouter<TMessage, MqttProducerEndpoint>.RouterFunction	routerFunction	The DictionaryOutboundRouter<TMessage, TEndpoint>.RouterFunction.
IReadOnlyDictionary<string, Action<IMqttProducerEndpointBuilder>>	endpointBuilderActions	The IReadOnlyDictionary<TKey, TValue> containing the key of each endpoint and the Action<T> to be invoked to build them.
MqttClientConfig	clientConfig	The MqttClientConfig.

MqttOutboundEndpointRouter(SingleEndpointRouterFunction, IReadOnlyDictionary<string, Action<IMqttProducerEndpointBuilder>>, MqttClientConfig)

Initializes a new instance of the MqttOutboundEndpointRouter<TMessage> class.

Declaration

public MqttOutboundEndpointRouter(DictionaryOutboundRouter<TMessage, MqttProducerEndpoint>.SingleEndpointRouterFunction routerFunction, IReadOnlyDictionary<string, Action<IMqttProducerEndpointBuilder>> endpointBuilderActions, MqttClientConfig clientConfig)

Parameters

Type	Name	Description
DictionaryOutboundRouter<TMessage, MqttProducerEndpoint>.SingleEndpointRouterFunction	routerFunction	The DictionaryOutboundRouter<TMessage, TEndpoint>.SingleEndpointRouterFunction.
IReadOnlyDictionary<string, Action<IMqttProducerEndpointBuilder>>	endpointBuilderActions	The IReadOnlyDictionary<TKey, TValue> containing the key of each endpoint and the Action<T> to be invoked to build them.
MqttClientConfig	clientConfig	The MqttClientConfig.

Implements

IOutboundRouter<TMessage>

IOutboundRouter