Interface EventCorrelation<TInstance, TData>

Namespace

MassTransit

Assembly

MassTransit.Abstractions.dll

public interface EventCorrelation<TInstance, TData> : EventCorrelation, ISpecification where TInstance : class, SagaStateMachineInstance where TData : class

Type Parameters

TInstance

TData

Inherited Members

EventCorrelation.DataType

EventCorrelation.ConfigureConsumeTopology

Extension Methods

ValidationResultExtensions.Failure(ISpecification, string)

ValidationResultExtensions.Failure(ISpecification, string, string)

ValidationResultExtensions.Failure(ISpecification, string, string, string)

ValidationResultExtensions.Success(ISpecification, string)

ValidationResultExtensions.Success(ISpecification, string, string)

ValidationResultExtensions.Success(ISpecification, string, string, string)

ValidationResultExtensions.Warning(ISpecification, string)

ValidationResultExtensions.Warning(ISpecification, string, string)

ValidationResultExtensions.Warning(ISpecification, string, string, string)

Properties

Event

Event<TData> Event { get; }

Property Value

Event<TData>

FilterFactory

The filter factory creates the filter when requested by the connector

SagaFilterFactory<TInstance, TData> FilterFactory { get; }

Property Value

SagaFilterFactory<TInstance, TData>

MessageFilter

The message filter which extracts the correlationId from the message

IFilter<ConsumeContext<TData>> MessageFilter { get; }

Property Value

IFilter<ConsumeContext<TData>>

Policy

Returns the saga policy for the event correlation

ISagaPolicy<TInstance, TData> Policy { get; }

Property Value

ISagaPolicy<TInstance, TData>