Interface IActivityObserver

Namespace

MassTransit

Assembly

MassTransit.Abstractions.dll

public interface IActivityObserver

Methods

CompensateFail<TActivity, TLog>(CompensateActivityContext<TActivity, TLog>, Exception)

Called after the message has been dispatched to all consumers when one or more exceptions have occurred

Task CompensateFail<TActivity, TLog>(CompensateActivityContext<TActivity, TLog> context, Exception exception) where TActivity : class, ICompensateActivity<TLog> where TLog : class

Parameters

context CompensateActivityContext<TActivity, TLog>

exception Exception

Returns

Task

Type Parameters

TActivity

TLog

ExecuteFault<TActivity, TArguments>(ExecuteActivityContext<TActivity, TArguments>, Exception)

Called after the message has been dispatched to all consumers when one or more exceptions have occurred

Task ExecuteFault<TActivity, TArguments>(ExecuteActivityContext<TActivity, TArguments> context, Exception exception) where TActivity : class, IExecuteActivity<TArguments> where TArguments : class

Parameters

context ExecuteActivityContext<TActivity, TArguments>

exception Exception

Returns

Task

Type Parameters

TActivity

TArguments

PostCompensate<TActivity, TLog>(CompensateActivityContext<TActivity, TLog>)

Called after the message has been dispatched to all consumers - note that in the case of an exception this method is not called, and the DispatchFaulted method is called instead

Task PostCompensate<TActivity, TLog>(CompensateActivityContext<TActivity, TLog> context) where TActivity : class, ICompensateActivity<TLog> where TLog : class

Parameters

context CompensateActivityContext<TActivity, TLog>

Returns

Task

Type Parameters

TActivity

TLog

PostExecute<TActivity, TArguments>(ExecuteActivityContext<TActivity, TArguments>)

Called after the message has been dispatched to all consumers - note that in the case of an exception this method is not called, and the DispatchFaulted method is called instead

Task PostExecute<TActivity, TArguments>(ExecuteActivityContext<TActivity, TArguments> context) where TActivity : class, IExecuteActivity<TArguments> where TArguments : class

Parameters

context ExecuteActivityContext<TActivity, TArguments>

Returns

Task

Type Parameters

TActivity

TArguments

PreCompensate<TActivity, TLog>(CompensateActivityContext<TActivity, TLog>)

Called before a message is dispatched to any consumers

Task PreCompensate<TActivity, TLog>(CompensateActivityContext<TActivity, TLog> context) where TActivity : class, ICompensateActivity<TLog> where TLog : class

Parameters

context CompensateActivityContext<TActivity, TLog>

The consume context

Returns

Task

Type Parameters

TActivity

TLog

PreExecute<TActivity, TArguments>(ExecuteActivityContext<TActivity, TArguments>)

Called before a message is dispatched to any consumers

Task PreExecute<TActivity, TArguments>(ExecuteActivityContext<TActivity, TArguments> context) where TActivity : class, IExecuteActivity<TArguments> where TArguments : class

Parameters

context ExecuteActivityContext<TActivity, TArguments>

The consume context

Returns

Task

Type Parameters

TActivity

TArguments