Class MqttBroker
An IBroker implementation for MQTT.
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.Broker
Assembly: Silverback.Integration.MQTT.dll
Syntax
public class MqttBroker : Broker<MqttProducerEndpoint, MqttConsumerEndpoint>, IBroker, IDisposable
Constructors
| Improve this doc View sourceMqttBroker(IServiceProvider)
Initializes a new instance of the MqttBroker class.
Declaration
public MqttBroker(IServiceProvider serviceProvider)
Parameters
Type | Name | Description |
---|---|---|
System.IServiceProvider | serviceProvider | The System.IServiceProvider to be used to resolve the required services. |
Methods
| Improve this doc View sourceInstantiateConsumer(MqttConsumerEndpoint, IBrokerBehaviorsProvider<IConsumerBehavior>, IServiceProvider)
Returns a new instance of IConsumer to subscribe to the specified endpoint.
Declaration
protected override IConsumer InstantiateConsumer(MqttConsumerEndpoint endpoint, IBrokerBehaviorsProvider<IConsumerBehavior> behaviorsProvider, IServiceProvider serviceProvider)
Parameters
Type | Name | Description |
---|---|---|
MqttConsumerEndpoint | endpoint | |
IBrokerBehaviorsProvider<IConsumerBehavior> | behaviorsProvider | |
System.IServiceProvider | serviceProvider | The System.IServiceProvider instance to be used to resolve the needed types or to be forwarded to the consumer. |
Returns
Type | Description |
---|---|
IConsumer | The instantiated IConsumer. |
Overrides
Silverback.Messaging.Broker.Broker<Silverback.Messaging.MqttProducerEndpoint, Silverback.Messaging.MqttConsumerEndpoint>.InstantiateConsumer(Silverback.Messaging.MqttConsumerEndpoint, Silverback.Messaging.Broker.Behaviors.IBrokerBehaviorsProvider<Silverback.Messaging.Broker.Behaviors.IConsumerBehavior>, System.IServiceProvider)
|
Improve this doc
View source
InstantiateProducer(MqttProducerEndpoint, IBrokerBehaviorsProvider<IProducerBehavior>, IServiceProvider)
Returns a new instance of IProducer to publish to the specified endpoint. The returned instance will be cached and reused for the same endpoint.
Declaration
protected override IProducer InstantiateProducer(MqttProducerEndpoint endpoint, IBrokerBehaviorsProvider<IProducerBehavior> behaviorsProvider, IServiceProvider serviceProvider)
Parameters
Type | Name | Description |
---|---|---|
MqttProducerEndpoint | endpoint | |
IBrokerBehaviorsProvider<IProducerBehavior> | behaviorsProvider | |
System.IServiceProvider | serviceProvider | The System.IServiceProvider instance to be used to resolve the needed types or to be forwarded to the consumer. |
Returns
Type | Description |
---|---|
IProducer | The instantiated IProducer. |
Overrides
Silverback.Messaging.Broker.Broker<Silverback.Messaging.MqttProducerEndpoint, Silverback.Messaging.MqttConsumerEndpoint>.InstantiateProducer(Silverback.Messaging.MqttProducerEndpoint, Silverback.Messaging.Broker.Behaviors.IBrokerBehaviorsProvider<Silverback.Messaging.Broker.Behaviors.IProducerBehavior>, System.IServiceProvider)
Implements
System.IDisposable