Class MqttProducerEndpointBuilder

Inheritance
System.Object
EndpointBuilder<MqttProducerEndpoint, IMqttProducerEndpointBuilder>
ProducerEndpointBuilder<MqttProducerEndpoint, IMqttProducerEndpointBuilder>
MqttProducerEndpointBuilder
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 MqttProducerEndpointBuilder : ProducerEndpointBuilder<MqttProducerEndpoint, IMqttProducerEndpointBuilder>, IMqttProducerEndpointBuilder, IProducerEndpointBuilder<IMqttProducerEndpointBuilder>, IEndpointBuilder<IMqttProducerEndpointBuilder>

Constructors

| Improve this doc View source

MqttProducerEndpointBuilder(MqttClientConfig, Type, IEndpointsConfigurationBuilder)

Initializes a new instance of the MqttProducerEndpointBuilder class.

Declaration
public MqttProducerEndpointBuilder(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 produced.
IEndpointsConfigurationBuilder endpointsConfigurationBuilder

The optional reference to the IEndpointsConfigurationBuilder that instantiated the builder.

Properties

| Improve this doc View source

This

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

Methods

| Improve this doc View source

Configure(Action<IMqttClientConfigBuilder>)

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

Configure(Action<MqttClientConfig>)

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

CreateEndpoint()

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

ProduceTo(Func<IOutboundEnvelope, IServiceProvider, String>)

Declaration
public IMqttProducerEndpointBuilder ProduceTo(Func<IOutboundEnvelope, IServiceProvider, string> topicNameFunction)
Parameters
Type Name Description
System.Func<IOutboundEnvelope, System.IServiceProvider, System.String> topicNameFunction
Returns
Type Description
IMqttProducerEndpointBuilder
| Improve this doc View source

ProduceTo(Func<IOutboundEnvelope, String>)

Declaration
public IMqttProducerEndpointBuilder ProduceTo(Func<IOutboundEnvelope, string> topicNameFunction)
Parameters
Type Name Description
System.Func<IOutboundEnvelope, System.String> topicNameFunction
Returns
Type Description
IMqttProducerEndpointBuilder
| Improve this doc View source

ProduceTo(String)

Declaration
public IMqttProducerEndpointBuilder ProduceTo(string topicName)
Parameters
Type Name Description
System.String topicName
Returns
Type Description
IMqttProducerEndpointBuilder
| Improve this doc View source

ProduceTo(String, Func<IOutboundEnvelope, String[]>)

Declaration
public IMqttProducerEndpointBuilder ProduceTo(string topicNameFormatString, Func<IOutboundEnvelope, string[]> topicNameArgumentsFunction)
Parameters
Type Name Description
System.String topicNameFormatString
System.Func<IOutboundEnvelope, System.String[]> topicNameArgumentsFunction
Returns
Type Description
IMqttProducerEndpointBuilder
| Improve this doc View source

ProduceTo<TMessage>(Func<IOutboundEnvelope<TMessage>, IServiceProvider, String>)

Declaration
public IMqttProducerEndpointBuilder ProduceTo<TMessage>(Func<IOutboundEnvelope<TMessage>, IServiceProvider, string> topicNameFunction)

    where TMessage : class
Parameters
Type Name Description
System.Func<IOutboundEnvelope<TMessage>, System.IServiceProvider, System.String> topicNameFunction
Returns
Type Description
IMqttProducerEndpointBuilder
Type Parameters
Name Description
TMessage
| Improve this doc View source

ProduceTo<TMessage>(Func<IOutboundEnvelope<TMessage>, String>)

Declaration
public IMqttProducerEndpointBuilder ProduceTo<TMessage>(Func<IOutboundEnvelope<TMessage>, string> topicNameFunction)

    where TMessage : class
Parameters
Type Name Description
System.Func<IOutboundEnvelope<TMessage>, System.String> topicNameFunction
Returns
Type Description
IMqttProducerEndpointBuilder
Type Parameters
Name Description
TMessage
| Improve this doc View source

ProduceTo<TMessage>(String, Func<IOutboundEnvelope<TMessage>, String[]>)

Declaration
public IMqttProducerEndpointBuilder ProduceTo<TMessage>(string topicNameFormatString, Func<IOutboundEnvelope<TMessage>, string[]> topicNameArgumentsFunction)

    where TMessage : class
Parameters
Type Name Description
System.String topicNameFormatString
System.Func<IOutboundEnvelope<TMessage>, System.String[]> topicNameArgumentsFunction
Returns
Type Description
IMqttProducerEndpointBuilder
Type Parameters
Name Description
TMessage
| Improve this doc View source

Retain()

Declaration
public IMqttProducerEndpointBuilder Retain()
Returns
Type Description
IMqttProducerEndpointBuilder
| Improve this doc View source

UseEndpointNameResolver<TResolver>()

Declaration
public IMqttProducerEndpointBuilder UseEndpointNameResolver<TResolver>()

    where TResolver : IProducerEndpointNameResolver
Returns
Type Description
IMqttProducerEndpointBuilder
Type Parameters
Name Description
TResolver
| Improve this doc View source

WithAtLeastOnceQoS()

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

WithAtMostOnceQoS()

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

WithExactlyOnceQoS()

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

WithMessageExpiration(TimeSpan)

Declaration
public IMqttProducerEndpointBuilder WithMessageExpiration(TimeSpan messageExpiryInterval)
Parameters
Type Name Description
System.TimeSpan messageExpiryInterval
Returns
Type Description
IMqttProducerEndpointBuilder
| Improve this doc View source

WithQualityOfServiceLevel(MqttQualityOfServiceLevel)

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

Implements

Extension Methods