Class ReplyingMessageProcessor<TInput, TOutput>

Namespace

Tp.RabbitMq

Assembly

Tp.RabbitMq.dll

public class ReplyingMessageProcessor<TInput, TOutput> : IMessageProcessor<TInput> where TOutput : class

Type Parameters

TInput

TOutput

Inheritance

object

ReplyingMessageProcessor<TInput, TOutput>

Implements

IMessageProcessor<TInput>

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

ReplyingMessageProcessor(IConnectionManager, IMessageSerializer<TOutput>, IMessageProcessorWithResult<TInput, TOutput>, ILogger, Func<TInput, Exception, TOutput>)

public ReplyingMessageProcessor(IConnectionManager connectionManager, IMessageSerializer<TOutput> serializer, IMessageProcessorWithResult<TInput, TOutput> inputMessageProcessor, ILogger logger, Func<TInput, Exception, TOutput> unexpectedResultProvider)

Parameters

connectionManager IConnectionManager

serializer IMessageSerializer<TOutput>

inputMessageProcessor IMessageProcessorWithResult<TInput, TOutput>

logger ILogger

unexpectedResultProvider Func<TInput, Exception, TOutput>

Methods

ProcessMessage(TInput, MessageProperties, CancellationToken)

public IMessageProcessorOutput ProcessMessage(TInput message, MessageProperties properties, CancellationToken cancellationToken)

Parameters

message TInput

properties MessageProperties

cancellationToken CancellationToken

Returns

IMessageProcessorOutput