Class MqttBroker

An IBroker implementation for MQTT.

Inheritance
System.Object
Broker<MqttProducerEndpoint, MqttConsumerEndpoint>
MqttBroker
Implements
System.IDisposable
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 source

MqttBroker(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 source

InstantiateConsumer(MqttConsumerEndpoint, IBrokerBehaviorsProvider<IConsumerBehavior>, IServiceProvider)

Declaration
protected override IConsumer InstantiateConsumer(MqttConsumerEndpoint endpoint, IBrokerBehaviorsProvider<IConsumerBehavior> behaviorsProvider, IServiceProvider serviceProvider)
Parameters
Type Name Description
MqttConsumerEndpoint endpoint
IBrokerBehaviorsProvider<IConsumerBehavior> behaviorsProvider
System.IServiceProvider serviceProvider
Returns
Type Description
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)

Declaration
protected override IProducer InstantiateProducer(MqttProducerEndpoint endpoint, IBrokerBehaviorsProvider<IProducerBehavior> behaviorsProvider, IServiceProvider serviceProvider)
Parameters
Type Name Description
MqttProducerEndpoint endpoint
IBrokerBehaviorsProvider<IProducerBehavior> behaviorsProvider
System.IServiceProvider serviceProvider
Returns
Type Description
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