Class ActivityDefinition<TActivity, TArguments, TLog>

Namespace

MassTransit

Assembly

MassTransit.Abstractions.dll

public class ActivityDefinition<TActivity, TArguments, TLog> : ExecuteActivityDefinition<TActivity, TArguments>, IActivityDefinition<TActivity, TArguments, TLog>, IActivityDefinition, IExecuteActivityDefinition<TActivity, TArguments>, IExecuteActivityDefinition, IDefinition where TActivity : class, IActivity<TArguments, TLog> where TArguments : class where TLog : class

Type Parameters

TActivity

TArguments

TLog

Inheritance

object

ExecuteActivityDefinition<TActivity, TArguments>

ActivityDefinition<TActivity, TArguments, TLog>

Implements

IActivityDefinition<TActivity, TArguments, TLog>

IActivityDefinition

IExecuteActivityDefinition<TActivity, TArguments>

IExecuteActivityDefinition

IDefinition

Inherited Members

ExecuteActivityDefinition<TActivity, TArguments>.ExecuteEndpoint(Action<IEndpointRegistrationConfigurator>)

ExecuteActivityDefinition<TActivity, TArguments>.ConfigureExecuteActivity(IReceiveEndpointConfigurator, IExecuteActivityConfigurator<TActivity, TArguments>)

ExecuteActivityDefinition<TActivity, TArguments>.ExecuteEndpointName

ExecuteActivityDefinition<TActivity, TArguments>.ExecuteEndpointDefinition

ExecuteActivityDefinition<TActivity, TArguments>.ConcurrentMessageLimit

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

ActivityDefinition()

public ActivityDefinition()

Properties

CompensateEndpointDefinition

Sets the endpoint definition, if available

public IEndpointDefinition<ICompensateActivity<TLog>>? CompensateEndpointDefinition { get; set; }

Property Value

IEndpointDefinition<ICompensateActivity<TLog>>

CompensateEndpointName

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 CompensateEndpointName { set; }

Property Value

string

Methods

CompensateEndpoint(Action<IEndpointRegistrationConfigurator>?)

Configure the compensate endpoint

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

Parameters

configure Action<IEndpointRegistrationConfigurator>

ConfigureCompensateActivity(IReceiveEndpointConfigurator, ICompensateActivityConfigurator<TActivity, TLog>)

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

protected virtual void ConfigureCompensateActivity(IReceiveEndpointConfigurator endpointConfigurator, ICompensateActivityConfigurator<TActivity, TLog> compensateActivityConfigurator)

Parameters

endpointConfigurator IReceiveEndpointConfigurator

The receive endpoint configurator for the consumer

compensateActivityConfigurator ICompensateActivityConfigurator<TActivity, TLog>