Class ReplyingMessageProcessorAsync<TInput, TOutput>

Namespace

Tp.RabbitMq

Assembly

Tp.RabbitMq.dll

public class ReplyingMessageProcessorAsync<TInput, TOutput> : IMessageProcessorAsync<TInput> where TOutput : class

Type Parameters

TInput

TOutput

Inheritance

object

ReplyingMessageProcessorAsync<TInput, TOutput>

Implements

IMessageProcessorAsync<TInput>

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

ReplyingMessageProcessorAsync(IConnectionManager, IMessageSerializerAsync<TOutput>, IMessageProcessorWithResultAsync<TInput, TOutput>, ILogger, Func<TInput, Exception, TOutput>)

public ReplyingMessageProcessorAsync(IConnectionManager connectionManager, IMessageSerializerAsync<TOutput> serializer, IMessageProcessorWithResultAsync<TInput, TOutput> inputMessageProcessor, ILogger logger, Func<TInput, Exception, TOutput> unexpectedResultProvider)

Parameters

connectionManager IConnectionManager

serializer IMessageSerializerAsync<TOutput>

inputMessageProcessor IMessageProcessorWithResultAsync<TInput, TOutput>

logger ILogger

unexpectedResultProvider Func<TInput, Exception, TOutput>

Methods

ProcessMessageAsync(TInput, MessageProperties, CancellationToken)

public Task<IMessageProcessorOutput> ProcessMessageAsync(TInput message, MessageProperties properties, CancellationToken cancellationToken)

Parameters

message TInput

properties MessageProperties

cancellationToken CancellationToken

Returns

Task<IMessageProcessorOutput>