Interface ICompensateActivityConfigurator<TActivity, TLog>

Namespace

MassTransit

Assembly

MassTransit.Abstractions.dll

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

public interface ICompensateActivityConfigurator<TActivity, TLog> : IPipeConfigurator<CompensateActivityContext<TActivity, TLog>>, IActivityObserverConnector, IConsumeConfigurator where TActivity : class, ICompensateActivity<TLog> where TLog : class

Type Parameters

TActivity

TLog

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

ActivityLog(Action<ICompensateActivityLogConfigurator<TLog>>)

Configure the arguments separate from the activity

void ActivityLog(Action<ICompensateActivityLogConfigurator<TLog>> configure)

Parameters

configure Action<ICompensateActivityLogConfigurator<TLog>>

Log(Action<ICompensateLogConfigurator<TLog>>)

void Log(Action<ICompensateLogConfigurator<TLog>> configure)

Parameters

configure Action<ICompensateLogConfigurator<TLog>>

RoutingSlip(Action<IRoutingSlipConfigurator>)

Configure the routing slip pipe

void RoutingSlip(Action<IRoutingSlipConfigurator> configure)

Parameters

configure Action<IRoutingSlipConfigurator>