Delegate SagaFilterFactory<TInstance, TData>

Namespace

MassTransit

Assembly

MassTransit.Abstractions.dll

public delegate IFilter<ConsumeContext<TData>> SagaFilterFactory<TInstance, TData>(ISagaRepository<TInstance> repository, ISagaPolicy<TInstance, TData> policy, IPipe<SagaConsumeContext<TInstance, TData>> sagaPipe) where TInstance : class, ISaga where TData : class

Parameters

repository ISagaRepository<TInstance>

policy ISagaPolicy<TInstance, TData>

sagaPipe IPipe<SagaConsumeContext<TInstance, TData>>

Returns

IFilter<ConsumeContext<TData>>

Type Parameters

TInstance

TData

Constructors

SagaFilterFactory(object, nint)

public SagaFilterFactory(object @object, nint method)

Parameters

object object

method nint

Methods

BeginInvoke(ISagaRepository<TInstance>, ISagaPolicy<TInstance, TData>, IPipe<SagaConsumeContext<TInstance, TData>>, AsyncCallback, object)

public virtual IAsyncResult BeginInvoke(ISagaRepository<TInstance> repository, ISagaPolicy<TInstance, TData> policy, IPipe<SagaConsumeContext<TInstance, TData>> sagaPipe, AsyncCallback callback, object @object)

Parameters

repository ISagaRepository<TInstance>

policy ISagaPolicy<TInstance, TData>

sagaPipe IPipe<SagaConsumeContext<TInstance, TData>>

callback AsyncCallback

object object

Returns

IAsyncResult

EndInvoke(IAsyncResult)

public virtual IFilter<ConsumeContext<TData>> EndInvoke(IAsyncResult result)

Parameters

result IAsyncResult

Returns

IFilter<ConsumeContext<TData>>

Invoke(ISagaRepository<TInstance>, ISagaPolicy<TInstance, TData>, IPipe<SagaConsumeContext<TInstance, TData>>)

public virtual IFilter<ConsumeContext<TData>> Invoke(ISagaRepository<TInstance> repository, ISagaPolicy<TInstance, TData> policy, IPipe<SagaConsumeContext<TInstance, TData>> sagaPipe)

Parameters

repository ISagaRepository<TInstance>

policy ISagaPolicy<TInstance, TData>

sagaPipe IPipe<SagaConsumeContext<TInstance, TData>>

Returns

IFilter<ConsumeContext<TData>>