Class ChaparConsumerAdapter<T>

Bridges the generic IMessageHandler<TMessage> to MassTransit's MassTransit.IConsumer<TMessage>, and applies the Inbox pattern for idempotent processing.

Inheritance

object

ChaparConsumerAdapter<T>

Implements

IConsumer<T>

IConsumer

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: Chapar.MassTransit.Consumers

Assembly: Chapar.MassTransit.dll

Syntax

public class ChaparConsumerAdapter<T> : IConsumer<T>, IConsumer where T : class, IMessage

Type Parameters

Name	Description
T

Constructors

ChaparConsumerAdapter(IMessageHandler<T>, IInboxStore?, IInboxMetrics?, IMessageContextAccessor?, ILogger<ChaparConsumerAdapter<T>>?)

Initializes a new instance of the ChaparConsumerAdapter<T> class.

Declaration

public ChaparConsumerAdapter(IMessageHandler<T> handler, IInboxStore? inboxStore = null, IInboxMetrics? inboxMetrics = null, IMessageContextAccessor? contextAccessor = null, ILogger<ChaparConsumerAdapter<T>>? logger = null)

Parameters

Type	Name	Description
IMessageHandler<T>	handler	The message handler to invoke upon successful processing.
IInboxStore	inboxStore	An optional inbox store for idempotent message reservation.
IInboxMetrics	inboxMetrics	An optional inbox metrics recorder for monitoring processed/duplicate/failed messages.
IMessageContextAccessor	contextAccessor	An optional message context accessor used to store headers for pipeline behaviors.
ILogger<ChaparConsumerAdapter<T>>	logger	An optional logger instance.

Methods

Consume(ConsumeContext<T>)

Declaration

public Task Consume(ConsumeContext<T> context)

Parameters

Type	Name	Description
ConsumeContext<T>	context

Returns

Type	Description
Task

Implements

MassTransit.IConsumer<TMessage>

MassTransit.IConsumer