Class FutureDefinition<TFuture>

Namespace

MassTransit

Assembly

MassTransit.Abstractions.dll

A future definition defines the configuration for a future, which can be used by the automatic registration code to configure the consumer on a receive endpoint.

public class FutureDefinition<TFuture> : IFutureDefinition<TFuture>, IFutureDefinition, IDefinition where TFuture : class, SagaStateMachine<FutureState>

Type Parameters

TFuture

Inheritance

object

FutureDefinition<TFuture>

Implements

IFutureDefinition<TFuture>

IFutureDefinition

IDefinition

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

FutureDefinition()

protected FutureDefinition()

Properties

ConcurrentMessageLimit

Set the concurrent message limit for the saga, which limits how many saga instances are able to concurrently consume messages.

public int? ConcurrentMessageLimit { get; protected set; }

Property Value

int?

EndpointDefinition

Sets the endpoint definition, if available

public IEndpointDefinition<TFuture>? EndpointDefinition { get; set; }

Property Value

IEndpointDefinition<TFuture>

EndpointName

Specify the endpoint name (which may be a queue, or a subscription, depending upon the transport) on which the saga should be configured.

protected string EndpointName { set; }

Property Value

string

Methods

ConfigureSaga(IReceiveEndpointConfigurator, ISagaConfigurator<FutureState>)

Called when configuring the saga on the endpoint. Configuration only applies to this saga, and does not apply to the endpoint.

protected virtual void ConfigureSaga(IReceiveEndpointConfigurator endpointConfigurator, ISagaConfigurator<FutureState> sagaConfigurator)

Parameters

endpointConfigurator IReceiveEndpointConfigurator

The receive endpoint configurator for the consumer

sagaConfigurator ISagaConfigurator<FutureState>

The saga configurator

Endpoint(Action<IEndpointRegistrationConfigurator>?)

Configure the saga endpoint

protected void Endpoint(Action<IEndpointRegistrationConfigurator>? configure = null)

Parameters

configure Action<IEndpointRegistrationConfigurator>