Class MqttConsumer

Inheritance

System.Object

Consumer

Consumer<MqttBroker, MqttConsumerEndpoint, MqttMessageIdentifier>

MqttConsumer

Implements

IConsumer

System.IDisposable

Inherited Members

Consumer<MqttBroker, MqttConsumerEndpoint, MqttMessageIdentifier>.Broker

Consumer<MqttBroker, MqttConsumerEndpoint, MqttMessageIdentifier>.Endpoint

Consumer<MqttBroker, MqttConsumerEndpoint, MqttMessageIdentifier>.CommitCoreAsync(IReadOnlyCollection<IBrokerMessageIdentifier>)

Consumer<MqttBroker, MqttConsumerEndpoint, MqttMessageIdentifier>.RollbackCoreAsync(IReadOnlyCollection<IBrokerMessageIdentifier>)

Consumer<MqttBroker, MqttConsumerEndpoint, MqttMessageIdentifier>.CommitCoreAsync(IReadOnlyCollection<MqttMessageIdentifier>)

Consumer<MqttBroker, MqttConsumerEndpoint, MqttMessageIdentifier>.RollbackCoreAsync(IReadOnlyCollection<MqttMessageIdentifier>)

Consumer.Id

Consumer.Broker

Consumer.Endpoint

Consumer.StatusInfo

Consumer.IsConnecting

Consumer.IsConnected

Consumer.IsConsuming

Consumer.IsDisconnecting

Consumer.ServiceProvider

Consumer.IsStopping

Consumer.ConnectAsync()

Consumer.DisconnectAsync()

Consumer.TriggerReconnectAsync()

Consumer.StartAsync()

Consumer.StopAsync()

Consumer.CommitAsync(IBrokerMessageIdentifier)

Consumer.CommitAsync(IReadOnlyCollection<IBrokerMessageIdentifier>)

Consumer.RollbackAsync(IBrokerMessageIdentifier)

Consumer.RollbackAsync(IReadOnlyCollection<IBrokerMessageIdentifier>)

Consumer.IncrementFailedAttempts(IRawInboundEnvelope)

Consumer.Dispose()

Consumer.CommitCoreAsync(IReadOnlyCollection<IBrokerMessageIdentifier>)

Consumer.RollbackCoreAsync(IReadOnlyCollection<IBrokerMessageIdentifier>)

Consumer.HandleMessageAsync(Byte[], IReadOnlyCollection<MessageHeader>, String, IBrokerMessageIdentifier, ISequenceStore)

Consumer.SetReadyStatus()

Consumer.RevertReadyStatus()

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 MqttConsumer : Consumer<MqttBroker, MqttConsumerEndpoint, MqttMessageIdentifier>, IConsumer, IDisposable

Constructors

| Improve this doc View source

MqttConsumer(MqttBroker, MqttConsumerEndpoint, IBrokerBehaviorsProvider<IConsumerBehavior>, IServiceProvider, IInboundLogger<MqttConsumer>)

Initializes a new instance of the MqttConsumer class.

Declaration

public MqttConsumer(MqttBroker broker, MqttConsumerEndpoint endpoint, IBrokerBehaviorsProvider<IConsumerBehavior> behaviorsProvider, IServiceProvider serviceProvider, IInboundLogger<MqttConsumer> logger)

Parameters

Type	Name	Description
MqttBroker	broker	The IBroker that is instantiating the consumer.
MqttConsumerEndpoint	endpoint	The endpoint to be consumed.
IBrokerBehaviorsProvider<IConsumerBehavior>	behaviorsProvider	The IBrokerBehaviorsProvider<TBehavior>.
System.IServiceProvider	serviceProvider	The System.IServiceProvider to be used to resolve the needed services.
IInboundLogger<MqttConsumer>	logger	The IInboundLogger<TCategoryName>.

Methods

| Improve this doc View source

CommitCoreAsync(IReadOnlyCollection<MqttMessageIdentifier>)

Declaration

protected override async Task CommitCoreAsync(IReadOnlyCollection<MqttMessageIdentifier> brokerMessageIdentifiers)

Parameters

Type	Name	Description
System.Collections.Generic.IReadOnlyCollection<MqttMessageIdentifier>	brokerMessageIdentifiers

Returns

Type	Description
System.Threading.Tasks.Task

Overrides

Silverback.Messaging.Broker.Consumer<Silverback.Messaging.Broker.MqttBroker, Silverback.Messaging.MqttConsumerEndpoint, Silverback.Messaging.Broker.MqttMessageIdentifier>.CommitCoreAsync(System.Collections.Generic.IReadOnlyCollection<Silverback.Messaging.Broker.MqttMessageIdentifier>)

| Improve this doc View source

ConnectCoreAsync()

Declaration

protected override Task ConnectCoreAsync()

Returns

Type	Description
System.Threading.Tasks.Task

Overrides

Consumer.ConnectCoreAsync()

| Improve this doc View source

DisconnectCoreAsync()

Declaration

protected override Task DisconnectCoreAsync()

Returns

Type	Description
System.Threading.Tasks.Task

Overrides

Consumer.DisconnectCoreAsync()

| Improve this doc View source

Dispose(Boolean)

Declaration

protected override void Dispose(bool disposing)

Parameters

Type	Name	Description
System.Boolean	disposing

Overrides

Consumer.Dispose(Boolean)

| Improve this doc View source

GetCurrentSequenceStores()

Declaration

public override IReadOnlyList<ISequenceStore> GetCurrentSequenceStores()

Returns

Type	Description
System.Collections.Generic.IReadOnlyList<ISequenceStore>

Overrides

Consumer.GetCurrentSequenceStores()

| Improve this doc View source

RollbackCoreAsync(IReadOnlyCollection<MqttMessageIdentifier>)

Declaration

protected override Task RollbackCoreAsync(IReadOnlyCollection<MqttMessageIdentifier> brokerMessageIdentifiers)

Parameters

Type	Name	Description
System.Collections.Generic.IReadOnlyCollection<MqttMessageIdentifier>	brokerMessageIdentifiers

Returns

Type	Description
System.Threading.Tasks.Task

Overrides

Silverback.Messaging.Broker.Consumer<Silverback.Messaging.Broker.MqttBroker, Silverback.Messaging.MqttConsumerEndpoint, Silverback.Messaging.Broker.MqttMessageIdentifier>.RollbackCoreAsync(System.Collections.Generic.IReadOnlyCollection<Silverback.Messaging.Broker.MqttMessageIdentifier>)

| Improve this doc View source

StartCoreAsync()

Declaration

protected override Task StartCoreAsync()

Returns

Type	Description
System.Threading.Tasks.Task

Overrides

Consumer.StartCoreAsync()

| Improve this doc View source

StopCoreAsync()

Declaration

protected override Task StopCoreAsync()

Returns

Type	Description
System.Threading.Tasks.Task

Overrides

Consumer.StopCoreAsync()

| Improve this doc View source

WaitUntilConsumingStoppedCoreAsync()

Declaration

protected override Task WaitUntilConsumingStoppedCoreAsync()

Returns

Type	Description
System.Threading.Tasks.Task

Overrides

Consumer.WaitUntilConsumingStoppedCoreAsync()

Implements

IConsumer

System.IDisposable