Class QueueListenerWithDelayOnErrorAsync<TMessage>

Namespace

Tp.RabbitMq

Assembly

Tp.RabbitMq.dll

public class QueueListenerWithDelayOnErrorAsync<TMessage> : QueueListenerAsync<TMessage>, IQueueListener, IDisposable

Type Parameters

TMessage

Inheritance

object

QueueListenerBase

QueueListenerAsync<TMessage>

QueueListenerWithDelayOnErrorAsync<TMessage>

Implements

IQueueListener

IDisposable

Inherited Members

QueueListenerAsync<TMessage>.ProcessMessageAsync(BasicDeliverEventArgs, CancellationToken)

QueueListenerBase.Log

QueueListenerBase.Config

QueueListenerBase.RunAsync()

QueueListenerBase.AckMessageAsync(IModel, BasicDeliverEventArgs, Stopwatch)

QueueListenerBase.NackMessageAsync(IModel, BasicDeliverEventArgs, bool, Stopwatch)

QueueListenerBase.Dispose()

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

QueueListenerWithDelayOnErrorAsync(QueueListenerConfig, IConnectionManager, IChannelProvider, IMessageDeserializerAsync<TMessage>, Func<IMessageProcessorAsync<TMessage>>, ILogger, DelayConfig)

public QueueListenerWithDelayOnErrorAsync(QueueListenerConfig config, IConnectionManager connectionManager, IChannelProvider channelProvider, IMessageDeserializerAsync<TMessage> messageDeserializer, Func<IMessageProcessorAsync<TMessage>> messageProcessorFactory, ILogger logger, DelayConfig delayConfig)

Parameters

config QueueListenerConfig

connectionManager IConnectionManager

channelProvider IChannelProvider

messageDeserializer IMessageDeserializerAsync<TMessage>

messageProcessorFactory Func<IMessageProcessorAsync<TMessage>>

logger ILogger

delayConfig DelayConfig

Methods

InitMessageProcessorAsync(IModel, BasicDeliverEventArgs, CancellationToken)

protected override Task InitMessageProcessorAsync(IModel channel, BasicDeliverEventArgs eventArgs, CancellationToken cancellationToken)

Parameters

channel IModel

eventArgs BasicDeliverEventArgs

cancellationToken CancellationToken

Returns

Task

PerformCustomConfiguration(IModel)

protected override void PerformCustomConfiguration(IModel channel)

Parameters

channel IModel