Class ExecuteActivityDefinition<TActivity, TArguments>

Namespace

MassTransit

Assembly

MassTransit.Abstractions.dll

public class ExecuteActivityDefinition<TActivity, TArguments> : IExecuteActivityDefinition<TActivity, TArguments>, IExecuteActivityDefinition, IDefinition where TActivity : class, IExecuteActivity<TArguments> where TArguments : class

Type Parameters

TActivity

TArguments

Inheritance

object

ExecuteActivityDefinition<TActivity, TArguments>

Implements

IExecuteActivityDefinition<TActivity, TArguments>

IExecuteActivityDefinition

IDefinition

Derived

ActivityDefinition<TActivity, TArguments, TLog>

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

ExecuteActivityDefinition()

protected ExecuteActivityDefinition()

Properties

ConcurrentMessageLimit

Specify a concurrency limit, which is applied to the entire consumer, saga, or activity, regardless of message type.

public int? ConcurrentMessageLimit { get; protected set; }

Property Value

int?

ExecuteEndpointDefinition

Sets the endpoint definition, if available

public IEndpointDefinition<IExecuteActivity<TArguments>>? ExecuteEndpointDefinition { get; set; }

Property Value

IEndpointDefinition<IExecuteActivity<TArguments>>

ExecuteEndpointName

Specify the endpoint name (which may be a queue, or a subscription, depending upon the transport) on which the saga should be configured. Setting to null will use the supplied IEndpointNameFormatter to generate the endpoint name.

protected string ExecuteEndpointName { set; }

Property Value

string

Methods

ConfigureExecuteActivity(IReceiveEndpointConfigurator, IExecuteActivityConfigurator<TActivity, TArguments>)

Called when the compensate activity is being configured on the endpoint.

protected virtual void ConfigureExecuteActivity(IReceiveEndpointConfigurator endpointConfigurator, IExecuteActivityConfigurator<TActivity, TArguments> executeActivityConfigurator)

Parameters

endpointConfigurator IReceiveEndpointConfigurator

The receive endpoint configurator for the consumer

executeActivityConfigurator IExecuteActivityConfigurator<TActivity, TArguments>

ExecuteEndpoint(Action<IEndpointRegistrationConfigurator>?)

Configure the execute endpoint

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

Parameters

configure Action<IEndpointRegistrationConfigurator>