Class ActivityObservable

Namespace

MassTransit.Observables

Assembly

MassTransit.Abstractions.dll

public class ActivityObservable : Connectable<IActivityObserver>, IActivityObserver

Inheritance

object

Connectable<IActivityObserver>

ActivityObservable

Implements

IActivityObserver

Inherited Members

Connectable<IActivityObserver>.Connect(IActivityObserver)

Connectable<IActivityObserver>.ForEachAsync(Func<IActivityObserver, Task>)

Connectable<IActivityObserver>.ForEach(Action<IActivityObserver>)

Connectable<IActivityObserver>.All(Func<IActivityObserver, bool>)

Connectable<IActivityObserver>.Count

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

ActivityObservable()

public ActivityObservable()

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

public 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

public 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

public 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

public 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

public 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

public 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