Class RabbitConsumer

Inheritance

System.Object

Consumer

Consumer<RabbitBroker, RabbitConsumerEndpoint, RabbitDeliveryTag>

RabbitConsumer

Implements

IConsumer

System.IDisposable

Inherited Members

Consumer<RabbitBroker, RabbitConsumerEndpoint, RabbitDeliveryTag>.Broker

Consumer<RabbitBroker, RabbitConsumerEndpoint, RabbitDeliveryTag>.Endpoint

Consumer<RabbitBroker, RabbitConsumerEndpoint, RabbitDeliveryTag>.CommitCoreAsync(IReadOnlyCollection<IBrokerMessageIdentifier>)

Consumer<RabbitBroker, RabbitConsumerEndpoint, RabbitDeliveryTag>.RollbackCoreAsync(IReadOnlyCollection<IBrokerMessageIdentifier>)

Consumer<RabbitBroker, RabbitConsumerEndpoint, RabbitDeliveryTag>.CommitCoreAsync(IReadOnlyCollection<RabbitDeliveryTag>)

Consumer<RabbitBroker, RabbitConsumerEndpoint, RabbitDeliveryTag>.RollbackCoreAsync(IReadOnlyCollection<RabbitDeliveryTag>)

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()

Consumer.Dispose(Boolean)

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.RabbitMQ.dll

Syntax

public class RabbitConsumer : Consumer<RabbitBroker, RabbitConsumerEndpoint, RabbitDeliveryTag>, IConsumer, IDisposable

Constructors

RabbitConsumer(RabbitBroker, RabbitConsumerEndpoint, IBrokerBehaviorsProvider<IConsumerBehavior>, IServiceProvider, IInboundLogger<RabbitConsumer>)

Initializes a new instance of the RabbitConsumer class.

Declaration

public RabbitConsumer(RabbitBroker broker, RabbitConsumerEndpoint endpoint, IBrokerBehaviorsProvider<IConsumerBehavior> behaviorsProvider, IServiceProvider serviceProvider, IInboundLogger<RabbitConsumer> logger)

Parameters

Type	Name	Description
RabbitBroker	broker	The IBroker that is instantiating the consumer.
RabbitConsumerEndpoint	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<RabbitConsumer>	logger	The IInboundLogger<TCategoryName>.

Methods

CommitCoreAsync(IReadOnlyCollection<RabbitDeliveryTag>)

Declaration

protected override Task CommitCoreAsync(IReadOnlyCollection<RabbitDeliveryTag> brokerMessageIdentifiers)

Parameters

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

Returns

Type	Description
System.Threading.Tasks.Task

Overrides

Silverback.Messaging.Broker.Consumer<Silverback.Messaging.Broker.RabbitBroker, Silverback.Messaging.RabbitConsumerEndpoint, Silverback.Messaging.Broker.RabbitDeliveryTag>.CommitCoreAsync(System.Collections.Generic.IReadOnlyCollection<Silverback.Messaging.Broker.RabbitDeliveryTag>)

ConnectCoreAsync()

Declaration

protected override Task ConnectCoreAsync()

Returns

Type	Description
System.Threading.Tasks.Task

Overrides

Consumer.ConnectCoreAsync()

DisconnectCoreAsync()

Declaration

protected override async Task DisconnectCoreAsync()

Returns

Type	Description
System.Threading.Tasks.Task

Overrides

Consumer.DisconnectCoreAsync()

GetCurrentSequenceStores()

Declaration

public override IReadOnlyList<ISequenceStore> GetCurrentSequenceStores()

Returns

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

Overrides

Consumer.GetCurrentSequenceStores()

RollbackCoreAsync(IReadOnlyCollection<RabbitDeliveryTag>)

Declaration

protected override Task RollbackCoreAsync(IReadOnlyCollection<RabbitDeliveryTag> brokerMessageIdentifiers)

Parameters

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

Returns

Type	Description
System.Threading.Tasks.Task

Overrides

Silverback.Messaging.Broker.Consumer<Silverback.Messaging.Broker.RabbitBroker, Silverback.Messaging.RabbitConsumerEndpoint, Silverback.Messaging.Broker.RabbitDeliveryTag>.RollbackCoreAsync(System.Collections.Generic.IReadOnlyCollection<Silverback.Messaging.Broker.RabbitDeliveryTag>)

StartCoreAsync()

Declaration

protected override Task StartCoreAsync()

Returns

Type	Description
System.Threading.Tasks.Task

Overrides

Consumer.StartCoreAsync()

StopCoreAsync()

Declaration

protected override Task StopCoreAsync()

Returns

Type	Description
System.Threading.Tasks.Task

Overrides

Consumer.StopCoreAsync()

WaitUntilConsumingStoppedCoreAsync()

Declaration

protected override Task WaitUntilConsumingStoppedCoreAsync()

Returns

Type	Description
System.Threading.Tasks.Task

Overrides

Consumer.WaitUntilConsumingStoppedCoreAsync()

Implements

IConsumer

System.IDisposable