Class SagaConfigurationObservable

Namespace

MassTransit.Configuration

Assembly

MassTransit.Abstractions.dll

public class SagaConfigurationObservable : Connectable<ISagaConfigurationObserver>, ISagaConfigurationObserver

Inheritance

object

Connectable<ISagaConfigurationObserver>

SagaConfigurationObservable

Implements

ISagaConfigurationObserver

Inherited Members

Connectable<ISagaConfigurationObserver>.Connect(ISagaConfigurationObserver)

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

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

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

Connectable<ISagaConfigurationObserver>.Count

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

SagaConfigurationObservable()

public SagaConfigurationObservable()

Methods

SagaConfigured<TSaga>(ISagaConfigurator<TSaga>)

Called immediately after the saga configuration is completed, but before the saga pipeline is built.

public void SagaConfigured<TSaga>(ISagaConfigurator<TSaga> configurator) where TSaga : class, ISaga

Parameters

configurator ISagaConfigurator<TSaga>

Type Parameters

TSaga

SagaMessageConfigured<TSaga, TMessage>(ISagaMessageConfigurator<TSaga, TMessage>)

Called after the saga/message configuration is completed, but before the saga/message pipeline is built.

public void SagaMessageConfigured<TSaga, TMessage>(ISagaMessageConfigurator<TSaga, TMessage> configurator) where TSaga : class, ISaga where TMessage : class

Parameters

configurator ISagaMessageConfigurator<TSaga, TMessage>

Type Parameters

TSaga

TMessage

StateMachineSagaConfigured<TInstance>(ISagaConfigurator<TInstance>, SagaStateMachine<TInstance>)

Called immediately after the state machine saga configuration is completed, but before the saga pipeline is built. Note that SagaConfigured<TSaga>(ISagaConfigurator<TSaga>) method will also be called, for backwards compatibility

public void StateMachineSagaConfigured<TInstance>(ISagaConfigurator<TInstance> configurator, SagaStateMachine<TInstance> stateMachine) where TInstance : class, ISaga, SagaStateMachineInstance

Parameters

configurator ISagaConfigurator<TInstance>

stateMachine SagaStateMachine<TInstance>

Type Parameters

TInstance