Class QueueListenerAsync<TMessage>

Namespace

Tp.RabbitMq

Assembly

Tp.RabbitMq.dll

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

Type Parameters

TMessage

Inheritance

object

QueueListenerBase

QueueListenerAsync<TMessage>

Implements

IQueueListener

IDisposable

Derived

QueueListenerWithDelayOnErrorAsync<TMessage>

Inherited Members

QueueListenerBase.Log

QueueListenerBase.Config

QueueListenerBase.RunAsync()

QueueListenerBase.PerformCustomConfiguration(IModel)

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

QueueListenerAsync(QueueListenerConfig, IConnectionManager, IMessageDeserializerAsync<TMessage>, Func<IMessageProcessorAsync<TMessage>>, ILogger)

public QueueListenerAsync(QueueListenerConfig config, IConnectionManager connectionManager, IMessageDeserializerAsync<TMessage> messageDeserializer, Func<IMessageProcessorAsync<TMessage>> messageProcessorFactory, ILogger logger)

Parameters

config QueueListenerConfig

connectionManager IConnectionManager

messageDeserializer IMessageDeserializerAsync<TMessage>

messageProcessorFactory Func<IMessageProcessorAsync<TMessage>>

logger ILogger

Methods

InitMessageProcessorAsync(IModel, BasicDeliverEventArgs, CancellationToken)

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

Parameters

channel IModel

eventArgs BasicDeliverEventArgs

cancellationToken CancellationToken

Returns

Task

ProcessMessageAsync(BasicDeliverEventArgs, CancellationToken)

protected Task<IMessageProcessorOutput> ProcessMessageAsync(BasicDeliverEventArgs eventArgs, CancellationToken cancellationToken)

Parameters

eventArgs BasicDeliverEventArgs

cancellationToken CancellationToken

Returns

Task<IMessageProcessorOutput>