Class ChaparConsumeFilter<T>

Populates the ambient IMessageContext for the current consumed message.

Inheritance

object

ChaparConsumeFilter<T>

Implements

IFilter<ConsumeContext<T>>

IProbeSite

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: Chapar.MassTransit.Filters

Assembly: Chapar.MassTransit.dll

Syntax

public sealed class ChaparConsumeFilter<T> : IFilter<ConsumeContext<T>>, IProbeSite where T : class

Type Parameters

Name	Description
T

Constructors

ChaparConsumeFilter(IMessageContextAccessor)

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

Declaration

public ChaparConsumeFilter(IMessageContextAccessor contextAccessor)

Parameters

Type	Name	Description
IMessageContextAccessor	contextAccessor	The accessor used to set the ambient message context.

Methods

Probe(ProbeContext)

Declaration

public void Probe(ProbeContext context)

Parameters

Type	Name	Description
ProbeContext	context

Send(ConsumeContext<T>, IPipe<ConsumeContext<T>>)

Sends a context to a filter, such that it can be processed and then passed to the specified output pipe for further processing.

Declaration

public Task Send(ConsumeContext<T> context, IPipe<ConsumeContext<T>> next)

Parameters

Type	Name	Description
ConsumeContext<T>	context	The pipe context type
IPipe<ConsumeContext<T>>	next	The next pipe in the pipeline

Returns

Type	Description
Task	An awaitable Task

Implements

MassTransit.IFilter<TContext>

MassTransit.IProbeSite