Interface IExecuteActivityConfigurator<TActivity, TArguments>

Namespace

MassTransit

Assembly

MassTransit.Abstractions.dll

Configure the execution of the activity and arguments with some tasty middleware.

public interface IExecuteActivityConfigurator<TActivity, TArguments> : IPipeConfigurator<ExecuteActivityContext<TActivity, TArguments>>, IActivityObserverConnector, IConsumeConfigurator where TActivity : class, IExecuteActivity<TArguments> where TArguments : class

Type Parameters

TActivity

TArguments

Inherited Members

IActivityObserverConnector.ConnectActivityObserver(IActivityObserver)

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

ActivityArguments(Action<IExecuteActivityArgumentsConfigurator<TArguments>>)

Configure the arguments separate from the activity

void ActivityArguments(Action<IExecuteActivityArgumentsConfigurator<TArguments>> configure)

Parameters

configure Action<IExecuteActivityArgumentsConfigurator<TArguments>>

Arguments(Action<IExecuteArgumentsConfigurator<TArguments>>)

Configure the pipeline prior to the activity factory

void Arguments(Action<IExecuteArgumentsConfigurator<TArguments>> configure)

Parameters

configure Action<IExecuteArgumentsConfigurator<TArguments>>

RoutingSlip(Action<IRoutingSlipConfigurator>)

Configure the routing slip pipe

void RoutingSlip(Action<IRoutingSlipConfigurator> configure)

Parameters

configure Action<IRoutingSlipConfigurator>