Interface IConsumerMessageConfigurator<TConsumer, TMessage>

Namespace

MassTransit

Assembly

MassTransit.Abstractions.dll

public interface IConsumerMessageConfigurator<TConsumer, TMessage> : IPipeConfigurator<ConsumerConsumeContext<TConsumer, TMessage>> where TConsumer : class where TMessage : class

Type Parameters

TConsumer

TMessage

Extension Methods

DelegateConfigurationExtensions.UseExecuteAsync<TContext>(IPipeConfigurator<TContext>, Func<TContext, Task>)

DelegateConfigurationExtensions.UseExecute<TContext>(IPipeConfigurator<TContext>, Action<TContext>)

FilterConfigurationExtensions.UseFilter<T>(IPipeConfigurator<T>, IFilter<T>)

FilterConfigurationExtensions.UseFilter<TContext, TFilter>(IPipeConfigurator<TContext>, IFilter<TFilter>, MergeFilterContextProvider<TContext, TFilter>, FilterContextProvider<TFilter, TContext>)

FilterConfigurationExtensions.UseFilters<T>(IPipeConfigurator<T>, params IFilter<T>[])

FilterConfigurationExtensions.UseFilters<T>(IPipeConfigurator<T>, IEnumerable<IFilter<T>>)

Methods

Message(Action<IConsumerMessageConfigurator<TMessage>>)

Add middleware to the consumer pipeline, for the specified message type, which is invoked after the consumer factory.

void Message(Action<IConsumerMessageConfigurator<TMessage>> configure)

Parameters

configure Action<IConsumerMessageConfigurator<TMessage>>

The callback to configure the message pipeline