Interface IBusFactoryConfigurator

Namespace

MassTransit

Assembly

MassTransit.Abstractions.dll

public interface IBusFactoryConfigurator : IReceiveConfigurator, IEndpointConfigurationObserverConnector, IConsumePipeConfigurator, IPipeConfigurator<ConsumeContext>, IConsumerConfigurationObserverConnector, ISagaConfigurationObserverConnector, IHandlerConfigurationObserverConnector, IActivityConfigurationObserverConnector, IConsumerConfigurationObserver, ISagaConfigurationObserver, IHandlerConfigurationObserver, IActivityConfigurationObserver, ISendPipelineConfigurator, IPublishPipelineConfigurator, IBusObserverConnector, IReceiveObserverConnector, IConsumeObserverConnector, ISendObserverConnector, IPublishObserverConnector

Inherited Members

IReceiveConfigurator.ReceiveEndpoint(IEndpointDefinition, IEndpointNameFormatter, Action<IReceiveEndpointConfigurator>)

IReceiveConfigurator.ReceiveEndpoint(string, Action<IReceiveEndpointConfigurator>)

IEndpointConfigurationObserverConnector.ConnectEndpointConfigurationObserver(IEndpointConfigurationObserver)

IConsumePipeConfigurator.AutoStart

IActivityConfigurationObserverConnector.ConnectActivityConfigurationObserver(IActivityConfigurationObserver)

ISendPipelineConfigurator.ConfigureSend(Action<ISendPipeConfigurator>)

IPublishPipelineConfigurator.ConfigurePublish(Action<IPublishPipeConfigurator>)

IBusObserverConnector.ConnectBusObserver(IBusObserver)

IReceiveObserverConnector.ConnectReceiveObserver(IReceiveObserver)

IConsumeObserverConnector.ConnectConsumeObserver(IConsumeObserver)

ISendObserverConnector.ConnectSendObserver(ISendObserver)

IPublishObserverConnector.ConnectPublishObserver(IPublishObserver)

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 { set; }

Property Value

int?

ConsumeTopology

IConsumeTopologyConfigurator ConsumeTopology { get; }

Property Value

IConsumeTopologyConfigurator

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

DeployPublishTopology

Deploys defined Publish message types to the broker at startup

bool DeployPublishTopology { set; }

Property Value

bool

DeployTopologyOnly

Set to true if the topology should be deployed only

bool DeployTopologyOnly { set; }

Property Value

bool

MessageTopology

IMessageTopologyConfigurator MessageTopology { get; }

Property Value

IMessageTopologyConfigurator

PrefetchCount

Specify the number of messages to prefetch from the message broker

int PrefetchCount { set; }

Property Value

int

The limit

PublishTopology

IPublishTopologyConfigurator PublishTopology { get; }

Property Value

IPublishTopologyConfigurator

SendTopology

ISendTopologyConfigurator SendTopology { get; }

Property Value

ISendTopologyConfigurator

SerializerContentType

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

ContentType SerializerContentType { set; }

Property Value

ContentType

Methods

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

Message<T>(Action<IMessageTopologyConfigurator<T>>)

Configure the message topology for the message type (global across all bus instances of the same transport type)

void Message<T>(Action<IMessageTopologyConfigurator<T>> configureTopology) where T : class

Parameters

configureTopology Action<IMessageTopologyConfigurator<T>>

Type Parameters

T

Publish<T>(Action<IMessagePublishTopologyConfigurator<T>>)

Configure the send topology of the message type

void Publish<T>(Action<IMessagePublishTopologyConfigurator<T>> configureTopology) where T : class

Parameters

configureTopology Action<IMessagePublishTopologyConfigurator<T>>

Type Parameters

T

Send<T>(Action<IMessageSendTopologyConfigurator<T>>)

Configure the send topology of the message type

void Send<T>(Action<IMessageSendTopologyConfigurator<T>> configureTopology) where T : class

Parameters

configureTopology Action<IMessageSendTopologyConfigurator<T>>

Type Parameters

T