Class QueueListener<TMessage>

Namespace

Tp.RabbitMq

Assembly

Tp.RabbitMq.dll

public sealed class QueueListener<TMessage> : QueueListenerBase, IQueueListener, IDisposable

Type Parameters

TMessage

Inheritance

object

QueueListenerBase

QueueListener<TMessage>

Implements

IQueueListener

IDisposable

Inherited Members

QueueListenerBase.RunAsync()

QueueListenerBase.Dispose()

object.GetType()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

QueueListener(QueueListenerConfig, IConnectionManager, IMessageDeserializer<TMessage>, Func<IMessageProcessor<TMessage>>, ILogger)

public QueueListener(QueueListenerConfig config, IConnectionManager connectionManager, IMessageDeserializer<TMessage> messageDeserializer, Func<IMessageProcessor<TMessage>> messageProcessorFactory, ILogger logger)

Parameters

config QueueListenerConfig

connectionManager IConnectionManager

messageDeserializer IMessageDeserializer<TMessage>

messageProcessorFactory Func<IMessageProcessor<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