Table of Contents

Interface IMessageConsumeTopologyConfigurator<TMessage>

Namespace
MassTransit
Assembly
MassTransit.Abstractions.dll

Configures the Consuming of a message type, allowing filters to be applied on Consume.

public interface IMessageConsumeTopologyConfigurator<TMessage> : IMessageConsumeTopologyConfigurator, ISpecification, IMessageConsumeTopology<TMessage> where TMessage : class

Type Parameters

TMessage
Inherited Members
Extension Methods

Properties

ConfigureConsumeTopology

Specify whether the broker topology should be configured for this message type (defaults to true)

bool ConfigureConsumeTopology { get; set; }

Property Value

bool

Methods

Add(IMessageConsumeTopology<TMessage>) 

void Add(IMessageConsumeTopology<TMessage> consumeTopology)

Parameters

consumeTopology IMessageConsumeTopology<TMessage>

AddDelegate(IMessageConsumeTopology<TMessage>)

Adds a delegated configuration to the Consume topology, which is called before any topologies in this configuration.

void AddDelegate(IMessageConsumeTopology<TMessage> configuration)

Parameters

configuration IMessageConsumeTopology<TMessage>

AddOrUpdateConvention<TConvention>(Func<TConvention>, Func<TConvention, TConvention>)

Returns the first convention that matches the interface type specified, to allow it to be customized and or replaced.

void AddOrUpdateConvention<TConvention>(Func<TConvention> add, Func<TConvention, TConvention> update) where TConvention : class, IMessageConsumeTopologyConvention<TMessage>

Parameters

add Func<TConvention>

Called if the convention does not already exist

update Func<TConvention, TConvention>

Called if the convention already exists

Type Parameters

TConvention

TryAddConvention(IMessageConsumeTopologyConvention<TMessage>)

Adds a convention to the message Consume topology configuration, which can be modified

bool TryAddConvention(IMessageConsumeTopologyConvention<TMessage> convention)

Parameters

convention IMessageConsumeTopologyConvention<TMessage>

Returns

bool

UpdateConvention<TConvention>(Func<TConvention, TConvention>)

Update a convention if available, otherwise, throw an exception

void UpdateConvention<TConvention>(Func<TConvention, TConvention> update) where TConvention : class, IMessageConsumeTopologyConvention<TMessage>

Parameters

update Func<TConvention, TConvention>

Called if the convention already exists

Type Parameters

TConvention