Interface IReceiveEndpointConfigurator

Namespace

MassTransit

Assembly

MassTransit.Abstractions.dll

Configure a receiving endpoint

public interface IReceiveEndpointConfigurator : IEndpointConfigurator, IConsumePipeConfigurator, IPipeConfigurator<ConsumeContext>, IConsumerConfigurationObserverConnector, ISagaConfigurationObserverConnector, IHandlerConfigurationObserverConnector, IActivityConfigurationObserverConnector, IConsumerConfigurationObserver, ISagaConfigurationObserver, IHandlerConfigurationObserver, IActivityConfigurationObserver, ISendPipelineConfigurator, IPublishPipelineConfigurator, IReceivePipelineConfigurator, IReceiveEndpointObserverConnector

Inherited Members

IConsumePipeConfigurator.AutoStart

IActivityConfigurationObserverConnector.ConnectActivityConfigurationObserver(IActivityConfigurationObserver)

ISendPipelineConfigurator.ConfigureSend(Action<ISendPipeConfigurator>)

IPublishPipelineConfigurator.ConfigurePublish(Action<IPublishPipeConfigurator>)

IReceivePipelineConfigurator.ConfigureReceive(Action<IReceivePipeConfigurator>)

IReceivePipelineConfigurator.ConfigureDeadLetter(Action<IPipeConfigurator<ReceiveContext>>)

IReceivePipelineConfigurator.ConfigureError(Action<IPipeConfigurator<ExceptionReceiveContext>>)

IReceivePipelineConfigurator.ConfigureTransport(Action<ITransportConfigurator>)

IReceiveEndpointObserverConnector.ConnectReceiveEndpointObserver(IReceiveEndpointObserver)

Extension Methods

FilterConfigurationExtensions.UseFilter<T>(IConsumePipeConfigurator, IFilter<ConsumeContext<T>>)

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

Properties

ConcurrentMessageLimit

Specify the number of concurrent messages that can be consumed (separate from prefetch count)

int? ConcurrentMessageLimit { get; set; }

Property Value

int?

ConfigureConsumeTopology

If true (the default), the broker topology is configured using the message types consumed by handlers, consumers, sagas, and activities. The implementation is broker-specific, but generally supported enough to be implemented across the board. This method obsoletes the previous methods, such as BindMessageTopics, BindMessageExchanges, SubscribeMessageTopics, etc.

bool ConfigureConsumeTopology { set; }

Property Value

bool

DefaultContentType

When deserializing a message, if no ContentType is present on the receive context, use this as the default

ContentType DefaultContentType { set; }

Property Value

ContentType

InputAddress

Returns the input address of the receive endpoint

Uri InputAddress { get; }

Property Value

Uri

PrefetchCount

Specify the number of messages to prefetch from the message broker

int PrefetchCount { get; set; }

Property Value

int

The limit

PublishFaults

If true (the default), faults should be published when no ResponseAddress or FaultAddress are present.

bool PublishFaults { set; }

Property Value

bool

SerializerContentType

When serializing a message, use the content type specified for serialization

ContentType SerializerContentType { set; }

Property Value

ContentType

Methods

AddDependency(IReceiveEndpointObserverConnector)

Add the observable receive endpoint as a dependency

void AddDependency(IReceiveEndpointObserverConnector connector)

Parameters

connector IReceiveEndpointObserverConnector

AddDeserializer(ISerializerFactory, bool)

Add a message deserializer using the specified factory (can be shared by serializer/deserializer)

void AddDeserializer(ISerializerFactory factory, bool isDefault = false)

Parameters

factory ISerializerFactory

isDefault bool

If true, set the default content type to the content type of the deserializer

AddSerializer(ISerializerFactory, bool)

Add a message serializer using the specified factory (can be shared by serializer/deserializer)

void AddSerializer(ISerializerFactory factory, bool isSerializer = true)

Parameters

factory ISerializerFactory

isSerializer bool

If true, set the current serializer to the specified factory

ClearSerialization()

Clears all message serialization configuration

void ClearSerialization()

ConfigureMessageTopology<T>(bool)

Configures whether the broker topology is configured for the specified message type. Related to ConfigureConsumeTopology, but for an individual message type.

void ConfigureMessageTopology<T>(bool enabled = true) where T : class

Parameters

enabled bool

Type Parameters

T