Class MqttOutboundEndpointRouter<TMessage>
Routes the outbound messages to one or multiple MQTT endpoints.
Inheritance
System.Object
OutboundRouter<TMessage>
DictionaryOutboundRouter<TMessage, MqttProducerEndpoint>
MqttOutboundEndpointRouter<TMessage>
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.Outbound.Routing
Assembly: Silverback.Integration.MQTT.dll
Syntax
public class MqttOutboundEndpointRouter<TMessage> : DictionaryOutboundRouter<TMessage, MqttProducerEndpoint>, IOutboundRouter<TMessage>, IOutboundRouterType Parameters
| Name | Description |
|---|---|
| TMessage | The type of the messages to be routed. |
Constructors
| Improve this doc View sourceMqttOutboundEndpointRouter(DictionaryOutboundRouter<TMessage, MqttProducerEndpoint>.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.RouterFunction<> | routerFunction | The DictionaryOutboundRouter<TMessage, TEndpoint>.RouterFunction. |
| System.Collections.Generic.IReadOnlyDictionary<System.String, System.Action<IMqttProducerEndpointBuilder>> | endpointBuilderActions | The System.Collections.Generic.IReadOnlyDictionary<TKey, TValue> containing the key of each endpoint and the System.Action<T> to be invoked to build them. |
| MqttClientConfig | clientConfig | The MqttClientConfig. |
MqttOutboundEndpointRouter(DictionaryOutboundRouter<TMessage, MqttProducerEndpoint>.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.SingleEndpointRouterFunction<> | routerFunction | The DictionaryOutboundRouter<TMessage, TEndpoint>.SingleEndpointRouterFunction. |
| System.Collections.Generic.IReadOnlyDictionary<System.String, System.Action<IMqttProducerEndpointBuilder>> | endpointBuilderActions | The System.Collections.Generic.IReadOnlyDictionary<TKey, TValue> containing the key of each endpoint and the System.Action<T> to be invoked to build them. |
| MqttClientConfig | clientConfig | The MqttClientConfig. |