Class ChaparConsumerAdapter<T, THandler>

Bridges IMessageHandler<TMessage> implementations to MassTransit's MassTransit.IConsumer<TMessage> pipeline, applies Inbox-based idempotent processing, and records inbox processing metrics.

Inheritance

object

ChaparConsumerAdapter<T, THandler>

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, THandler> : IConsumer<T>, IConsumer where T : class, IMessage where THandler : IMessageHandler<T>

Type Parameters

Name	Description
T
THandler

Constructors

ChaparConsumerAdapter(THandler, IInboxStore?, IInboxMetrics?, ILogger<ChaparConsumerAdapter<T, THandler>>?)

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

Declaration

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

Parameters

Type	Name	Description
THandler	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.
ILogger<ChaparConsumerAdapter<T, THandler>>	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