Interface ISagaConfigurator<TSaga>

Namespace

MassTransit

Assembly

MassTransit.Abstractions.dll

public interface ISagaConfigurator<TSaga> : IPipeConfigurator<SagaConsumeContext<TSaga>>, ISagaConfigurationObserverConnector, IConsumeConfigurator, IOptionsSet where TSaga : class, ISaga

Type Parameters

TSaga

Inherited Members

IOptionsSet.Options<T>(Action<T>)

IOptionsSet.Options<T>(T, Action<T>)

IOptionsSet.TryGetOptions<T>(out T)

IOptionsSet.SelectOptions<T>()

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

Properties

ConcurrentMessageLimit

int? ConcurrentMessageLimit { set; }

Property Value

int?

Methods

Message<T>(Action<ISagaMessageConfigurator<T>>)

Add middleware to the message pipeline, which is invoked prior to the saga repository.

void Message<T>(Action<ISagaMessageConfigurator<T>> configure) where T : class

Parameters

configure Action<ISagaMessageConfigurator<T>>

The callback to configure the message pipeline

Type Parameters

T

The message type

SagaMessage<T>(Action<ISagaMessageConfigurator<TSaga, T>>)

Add middleware to the saga pipeline, for the specified message type, which is invoked after the saga repository.

void SagaMessage<T>(Action<ISagaMessageConfigurator<TSaga, T>> configure) where T : class

Parameters

configure Action<ISagaMessageConfigurator<TSaga, T>>

The callback to configure the message pipeline

Type Parameters

T

The message type