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
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
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