Class MqttConsumerEndpointBuilder

Inheritance
System.Object
EndpointBuilder<MqttConsumerEndpoint, IMqttConsumerEndpointBuilder>
ConsumerEndpointBuilder<MqttConsumerEndpoint, IMqttConsumerEndpointBuilder>
MqttConsumerEndpointBuilder
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.Configuration.Mqtt
Assembly: Silverback.Integration.MQTT.dll
Syntax
public class MqttConsumerEndpointBuilder : ConsumerEndpointBuilder<MqttConsumerEndpoint, IMqttConsumerEndpointBuilder>, IMqttConsumerEndpointBuilder, IConsumerEndpointBuilder<IMqttConsumerEndpointBuilder>, IEndpointBuilder<IMqttConsumerEndpointBuilder>

Constructors

| Improve this doc View source

MqttConsumerEndpointBuilder(MqttClientConfig, Type, IEndpointsConfigurationBuilder)

Initializes a new instance of the MqttConsumerEndpointBuilder class.

Declaration
public MqttConsumerEndpointBuilder(MqttClientConfig clientConfig, Type messageType = null, IEndpointsConfigurationBuilder endpointsConfigurationBuilder = null)
Parameters
Type Name Description
MqttClientConfig clientConfig

The MqttClientConfig.
System.Type messageType

The type of the message being consumed.
IEndpointsConfigurationBuilder endpointsConfigurationBuilder

The optional reference to the IEndpointsConfigurationBuilder that instantiated the builder.

Properties

| Improve this doc View source

This

Declaration
protected override IMqttConsumerEndpointBuilder This { get; }
Property Value
Type Description
IMqttConsumerEndpointBuilder
Overrides
Silverback.Messaging.Configuration.EndpointBuilder<Silverback.Messaging.MqttConsumerEndpoint, Silverback.Messaging.Configuration.Mqtt.IMqttConsumerEndpointBuilder>.This

Methods

| Improve this doc View source

Configure(Action<IMqttClientConfigBuilder>)

Declaration
public IMqttConsumerEndpointBuilder Configure(Action<IMqttClientConfigBuilder> configBuilderAction)
Parameters
Type Name Description
System.Action<IMqttClientConfigBuilder> configBuilderAction
Returns
Type Description
IMqttConsumerEndpointBuilder
| Improve this doc View source

Configure(Action<MqttClientConfig>)

Declaration
public IMqttConsumerEndpointBuilder Configure(Action<MqttClientConfig> configAction)
Parameters
Type Name Description
System.Action<MqttClientConfig> configAction
Returns
Type Description
IMqttConsumerEndpointBuilder
| Improve this doc View source

ConsumeFrom(String[])

Declaration
public IMqttConsumerEndpointBuilder ConsumeFrom(params string[] topics)
Parameters
Type Name Description
System.String[] topics
Returns
Type Description
IMqttConsumerEndpointBuilder
| Improve this doc View source

CreateEndpoint()

Declaration
protected override MqttConsumerEndpoint CreateEndpoint()
Returns
Type Description
MqttConsumerEndpoint
Overrides
Silverback.Messaging.Configuration.EndpointBuilder<Silverback.Messaging.MqttConsumerEndpoint, Silverback.Messaging.Configuration.Mqtt.IMqttConsumerEndpointBuilder>.CreateEndpoint()
| Improve this doc View source

DisableParallelProcessing()

Declaration
public IMqttConsumerEndpointBuilder DisableParallelProcessing()
Returns
Type Description
IMqttConsumerEndpointBuilder
| Improve this doc View source

EnableParallelProcessing(Int32)

Declaration
public IMqttConsumerEndpointBuilder EnableParallelProcessing(int maxDegreeOfParallelism)
Parameters
Type Name Description
System.Int32 maxDegreeOfParallelism
Returns
Type Description
IMqttConsumerEndpointBuilder
| Improve this doc View source

LimitBackpressure(Int32)

Declaration
public IMqttConsumerEndpointBuilder LimitBackpressure(int backpressureLimit)
Parameters
Type Name Description
System.Int32 backpressureLimit
Returns
Type Description
IMqttConsumerEndpointBuilder
| Improve this doc View source

WithAtLeastOnceQoS()

Declaration
public IMqttConsumerEndpointBuilder WithAtLeastOnceQoS()
Returns
Type Description
IMqttConsumerEndpointBuilder
| Improve this doc View source

WithAtMostOnceQoS()

Declaration
public IMqttConsumerEndpointBuilder WithAtMostOnceQoS()
Returns
Type Description
IMqttConsumerEndpointBuilder
| Improve this doc View source

WithExactlyOnceQoS()

Declaration
public IMqttConsumerEndpointBuilder WithExactlyOnceQoS()
Returns
Type Description
IMqttConsumerEndpointBuilder
| Improve this doc View source

WithQualityOfServiceLevel(MqttQualityOfServiceLevel)

Declaration
public IMqttConsumerEndpointBuilder WithQualityOfServiceLevel(MqttQualityOfServiceLevel qosLevel)
Parameters
Type Name Description
MQTTnet.Protocol.MqttQualityOfServiceLevel qosLevel
Returns
Type Description
IMqttConsumerEndpointBuilder

Implements

Extension Methods