Interface IMissingInstanceConfigurator<TSaga, TMessage>

Namespace

MassTransit

Assembly

MassTransit.Abstractions.dll

public interface IMissingInstanceConfigurator<TSaga, TMessage> where TSaga : SagaStateMachineInstance where TMessage : class

Type Parameters

TSaga

TMessage

Methods

Discard()

Discard the event, silently ignoring the missing instance for the event

IPipe<ConsumeContext<TMessage>> Discard()

Returns

IPipe<ConsumeContext<TMessage>>

Execute(Action<ConsumeContext<TMessage>>)

Execute a method when the instance is missed, allowing a custom behavior to be specified.

IPipe<ConsumeContext<TMessage>> Execute(Action<ConsumeContext<TMessage>> callback)

Parameters

callback Action<ConsumeContext<TMessage>>

Returns

IPipe<ConsumeContext<TMessage>>

ExecuteAsync(Func<ConsumeContext<TMessage>, Task>)

Execute an asynchronous method when the instance is missed, allowing a custom behavior to be specified.

IPipe<ConsumeContext<TMessage>> ExecuteAsync(Func<ConsumeContext<TMessage>, Task> callback)

Parameters

callback Func<ConsumeContext<TMessage>, Task>

Returns

IPipe<ConsumeContext<TMessage>>

Fault()

Fault the saga consumer, which moves the message to the error queue

IPipe<ConsumeContext<TMessage>> Fault()

Returns

IPipe<ConsumeContext<TMessage>>