Class QueueListenerBase

Namespace

Tp.RabbitMq

Assembly

Tp.RabbitMq.dll

public abstract class QueueListenerBase : IQueueListener, IDisposable

Inheritance

object

QueueListenerBase

Implements

IQueueListener

IDisposable

Derived

QueueListenerAsync<TMessage>

QueueListener<TMessage>

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

QueueListenerBase(QueueListenerConfig, IConnectionManager, ILogger)

protected QueueListenerBase(QueueListenerConfig config, IConnectionManager connectionManager, ILogger logger)

Parameters

config QueueListenerConfig

connectionManager IConnectionManager

logger ILogger

Fields

Config

protected readonly QueueListenerConfig Config

Field Value

QueueListenerConfig

Log

protected readonly ILogger Log

Field Value

ILogger

Methods

AckMessageAsync(IModel, BasicDeliverEventArgs, Stopwatch)

protected Task AckMessageAsync(IModel channel, BasicDeliverEventArgs eventArgs, Stopwatch timer)

Parameters

channel IModel

eventArgs BasicDeliverEventArgs

timer Stopwatch

Returns

Task

Dispose()

public void Dispose()

InitMessageProcessorAsync(IModel, BasicDeliverEventArgs, CancellationToken)

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

Parameters

channel IModel

eventArgs BasicDeliverEventArgs

cancellationToken CancellationToken

Returns

Task

NackMessageAsync(IModel, BasicDeliverEventArgs, bool, Stopwatch)

protected Task NackMessageAsync(IModel channel, BasicDeliverEventArgs eventArgs, bool requeue, Stopwatch timer)

Parameters

channel IModel

eventArgs BasicDeliverEventArgs

requeue bool

timer Stopwatch

Returns

Task

PerformCustomConfiguration(IModel)

protected virtual void PerformCustomConfiguration(IModel channel)

Parameters

channel IModel

RunAsync()

public Task RunAsync()

Returns

Task