Class MqttBroker

An IBroker implementation for MQTT.

Inheritance

object

Broker<MqttProducerEndpoint, MqttConsumerEndpoint>

MqttBroker

Implements

IBroker

IDisposable

Inherited Members

Broker<MqttProducerEndpoint, MqttConsumerEndpoint>.ProducerEndpointType

Broker<MqttProducerEndpoint, MqttConsumerEndpoint>.ConsumerEndpointType

Broker<MqttProducerEndpoint, MqttConsumerEndpoint>.Producers

Broker<MqttProducerEndpoint, MqttConsumerEndpoint>.Consumers

Broker<MqttProducerEndpoint, MqttConsumerEndpoint>.IsConnected

Broker<MqttProducerEndpoint, MqttConsumerEndpoint>.GetProducer(IProducerEndpoint)

Broker<MqttProducerEndpoint, MqttConsumerEndpoint>.GetProducer(string)

Broker<MqttProducerEndpoint, MqttConsumerEndpoint>.AddConsumer(IConsumerEndpoint)

Broker<MqttProducerEndpoint, MqttConsumerEndpoint>.ConnectAsync()

Broker<MqttProducerEndpoint, MqttConsumerEndpoint>.DisconnectAsync()

Broker<MqttProducerEndpoint, MqttConsumerEndpoint>.Dispose()

Broker<MqttProducerEndpoint, MqttConsumerEndpoint>.InstantiateProducer(MqttProducerEndpoint, IBrokerBehaviorsProvider<IProducerBehavior>, IServiceProvider)

Broker<MqttProducerEndpoint, MqttConsumerEndpoint>.InstantiateConsumer(MqttConsumerEndpoint, IBrokerBehaviorsProvider<IConsumerBehavior>, IServiceProvider)

Broker<MqttProducerEndpoint, MqttConsumerEndpoint>.ConnectAsync(IReadOnlyCollection<IProducer>, IReadOnlyCollection<IConsumer>)

Broker<MqttProducerEndpoint, MqttConsumerEndpoint>.DisconnectAsync(IReadOnlyCollection<IProducer>, IReadOnlyCollection<IConsumer>)

Broker<MqttProducerEndpoint, MqttConsumerEndpoint>.Dispose(bool)

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: Silverback.Messaging.Broker

Assembly: Silverback.Integration.MQTT.dll

Syntax

public class MqttBroker : Broker<MqttProducerEndpoint, MqttConsumerEndpoint>, IBroker, IDisposable

Constructors

MqttBroker(IServiceProvider)

Initializes a new instance of the MqttBroker class.

Declaration

public MqttBroker(IServiceProvider serviceProvider)

Parameters

Type	Name	Description
IServiceProvider	serviceProvider	The IServiceProvider to be used to resolve the required services.

Methods

InstantiateConsumer(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	The endpoint.
IBrokerBehaviorsProvider<IConsumerBehavior>	behaviorsProvider	The IBrokerBehaviorsProvider<TBehavior>.
IServiceProvider	serviceProvider	The 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

Broker<MqttProducerEndpoint, MqttConsumerEndpoint>.InstantiateConsumer(MqttConsumerEndpoint, IBrokerBehaviorsProvider<IConsumerBehavior>, IServiceProvider)

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	The endpoint.
IBrokerBehaviorsProvider<IProducerBehavior>	behaviorsProvider	The IBrokerBehaviorsProvider<TBehavior>.
IServiceProvider	serviceProvider	The 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

Broker<MqttProducerEndpoint, MqttConsumerEndpoint>.InstantiateProducer(MqttProducerEndpoint, IBrokerBehaviorsProvider<IProducerBehavior>, IServiceProvider)

Implements

IBroker

IDisposable