MassTransit
Namespace with 239 public types
Classes
ActiveJob
Active Jobs are allocated a concurrency slot, and are valid until the deadline is reached, after
which they may be automatically released.
ConsumeTopology
DefaultEndpointNameFormatter
The default endpoint name formatter, which simply trims the words Consumer, Activity, and Saga
from the type name. If you need something more readable, consider the
or the .
EndpointConventionCache`1
A cache of convention-based CorrelationId mappers, used unless overridden by some mystical force
GlobalTopology
This represents the global topology configuration, which is delegated to by
all topology instances, unless for some radical reason a bus is configured
without any topology delegation.
YES, I hate globals, but they are serving a purpose in that these are really
just defining the default behavior of message types, rather than actually
behaving like the nasty evil global variables.
InMemorySagaRepository`1
JobAttemptSaga
Each attempt to run a job is tracked by this state
JobAttemptStateMachine
JobOptions`1
JobOptions contains the options used to configure the job consumer and related components
JobSaga
Individual turnout jobs are tracked by this state
JobServiceOptions
JobStateMachine
JobTypeInstance
JobTypeSaga
Every job type has one entry in this state machine
JobTypeStateMachine
KebabCaseEndpointNameFormatter
Formats the endpoint names using kebab-case (dashed snake case)
SubmitOrderConsumer -> submit-order
OrderState -> order-state
UpdateCustomerActivity -> update-customer-execute, update-customer-compensate
ManagementEndpointDefinition
Specifies a management endpoint, with the prefix "manage"
MassTransitApplicationException
For use by application developers to include additional data elements along with the exception, which will be
transferred to the of the event.
MassTransitBus
MassTransitHostedService
MassTransitStateMachine`1
A MassTransit state machine adds functionality on top of Automatonymous supporting
things like request/response, and correlating events to the state machine, as well
as retry and policy configuration.
MessageConsumeTopology`1
RequestConsumerFuture`2
RoutingSlipBuilder
A RoutingSlipBuilder is used to create a routing slip with proper validation that the resulting RoutingSlip
is valid.
ServiceInstanceOptions
SnakeCaseEndpointNameFormatter
Formats the endpoint name using snake case. For example,
SubmitOrderConsumer -> submit_order
OrderState -> order_state
UpdateCustomerActivity -> update_customer_execute, update_customer_compensate
Structures
FutureLocation
InMemoryEndpointAddress
InMemoryHostAddress
Static Classes
ActivityObserverConfigurationExtensions
AsyncMessageListExtensions
AuditConfigurationExtensions
BatchConsumerExtensions
BindConfigurationExtensions
Bus
used to get access to the bus factories
BusControlExtensions
BusFactoryExtensions
BusHandleExtensions
CircuitBreakerConfigurationExtensions
ClientFactoryExtensions
ConcurrencyLimitConfigurationExtensions
ConcurrentMessageLimitExtensions
ConsumeContextEndpointExtensions
ConsumerConvention
Used to register conventions for consumer message types
ConsumerExtensions
ConsumerPipeConfiguratorExtensions
ContainerActivityExtensions
ContextFilterConfigurationExtensions
CorrelationIdConventionExtensions
CourierHostConfiguratorExtensions
DeadLetterExtensions
DelayedMessageSchedulerConfigurationExtensions
DelayedMessageSchedulerRegistrationExtensions
DelayedRedeliveryExtensions
DelegatePipeConfiguratorExtensions
DependencyInjectionExtensions
DependencyInjectionFilterExtensions
DependencyInjectionReceiveEndpointExtensions
DependencyInjectionRegistrationExtensions
Standard registration extensions, which are used to configure consumers, sagas, and activities on receive endpoints from a
dependency injection container.
DependencyInjectionTestingExtensions
DependencyInjectionTransactionExtensions
DispatchConfigurationExtensions
EndpointConvention
EndpointConventionCache
EndpointConventionExtensions
ForkConfigurationExtensions
ForwardExtensions
FutureExtensions
FutureResultConfiguratorExtensions
FutureStateExtensions
FutureVariableExtensions
HandlerExtensions
HostedServiceConfigurationExtensions
These are the updated extensions compatible with the container registration code. They should be used, for real.
InlineFilterConfigurationExtensions
InMemoryBus
InMemoryConfigurationExtensions
InMemoryOutboxConfigurationExtensions
InMemorySagaRepositoryRegistrationExtensions
InstanceExtensions
Extensions for subscribing object instances.
InstrumentationConfigurationExtensions
InterceptConfigurationExtensions
IntrospectionExtensions
JobServiceConfigurationExtensions
JobServiceContainerConfigurationExtensions
JobServiceEventExtensions
JsonSerializerConfigurationExtensions
KillSwitchConfigurationExtensions
LatestConfigurationExtensions
LegacySerializationExtensions
LogContext
MediatorConfigurationExtensions
MessageCorrelation
MessageDataConfiguratorExtensions
MessageDataExtensions
MessageRetryConfigurationExtensions
MessageSchedulerBusExtensions
MessageSchedulerExtensions
MessageSchedulerRegistrationExtensions
MissingInstanceRedeliveryExtensions
ObserverExtensions
ObserverRegistrationExtensions
PartitionerConfigurationExtensions
PerformanceCounterExtensions
PublishEndpointRecurringSchedulerExtensions
PublishExtensions
RateLimitConfigurationExtensions
RawJsonSerializerConfigurationExtensions
ReceiveEndpointConfigurationExtensions
ReceivePipeConfigurationExtensions
RedeliverExtensions
RegistrationConfiguratorExtensions
RegistrationContextExtensions
RegistrationExtensions
RequestEventExtensions
RequestExtensions
RescueConfigurationExtensions
RespondExtensions
Retry
RetryConfigurationExtensions
RoutingSlipEventExtensions
SagaExtensions
SagaPipeConfiguratorExtensions
SagaStateMachineExtensions
SagaStateMachineReceiveEndpointExtensions
ScheduleDateTimeExtensions
ScheduledRedeliveryConfigurationExtensions
ScheduleTimeSpanExtensions
SendByConventionExtensions
SendCallbackExtensions
SendEndpointRecurringSchedulerExtensions
SendExtensions
ServiceInstanceConfigurationExtensions
StateMachineExtensions
StateMachineIntrospectionExtensions
StateMachineRequestExtensions
SupervisorExtensions
ThenExtensions
TimeoutConfiguratorExtensions
TransactionConfiguratorExtensions
TransactionContextExtensions
TransformConfigurationExtensions
TransitionExtensions
Abstract Classes
Future`2
Future`3
A future is a deterministic, durable service that given a command, executes any number
of requests, routing slips, functions, etc. to produce a result. Once the result has been set,
it is available to any subsequent commands and requests for the result.
Interfaces
EventActivities`1
EventActivityBinder`1
EventActivityBinder`2
ExceptionActivityBinder`2
ExceptionActivityBinder`3
FutureRequestHandle`4
FutureResponseHandle`5
FutureRoutingSlipHandle
IAsyncPipeContextHandle`1
Supports the asynchronous notification of a PipeContext becoming available (this is a future of a future, basically)
IBindConfigurator`1
IBindConfigurator`2
Configures a binding using the specified pipe context source
IBusFactory
IBusFactorySelector
Use one of the selector extension methods to create a bus instance for the
selected transport.
IBusRegistrationConfigurator
Configures the container registration, and supports creation of a bus or a mediator.
IBusRegistrationConfigurator`1
Configures additional bus instances, configured via MultiBus
IBusRegistrationContext
ICircuitBreakerConfigurator`1
Configure the settings on the circuit breaker
IDispatchConfigurator`1
IEndpointConventionCache`1
IFutureFaultConfigurator`1
IFutureFaultConfigurator`2
IFutureRegistrationConfigurator
IFutureRegistrationConfigurator`1
IFutureRequestConfigurator`3
IFutureRequestDefinition`1
IFutureResponseConfigurator`2
IFutureResultConfigurator`1
IFutureResultConfigurator`2
IFutureRoutingSlipConfigurator`3
IGlobalTopology
IInMemoryBusFactoryConfigurator
IInMemoryBusTopology
IInMemoryConsumeTopology
IInMemoryConsumeTopologyConfigurator
IInMemoryHostConfigurator
IInMemoryMessageConsumeTopology`1
IInMemoryMessageConsumeTopologyConfigurator
IInMemoryMessageConsumeTopologyConfigurator`1
IInMemoryMessagePublishTopology
IInMemoryMessagePublishTopology`1
IInMemoryMessagePublishTopologyConfigurator
IInMemoryMessagePublishTopologyConfigurator`1
IInMemoryPublishTopology
IInMemoryPublishTopologyConfigurator
IInMemoryReceiveEndpointConfigurator
IItineraryPlanner`1
Implement to build a routing slip. This can be resolved by a durable future to build
a routing slip at runtime in response to an input command.
IJobServiceConfigurator
ILatestConfigurator`1
IMediatorConfigurator
IMediatorRegistrationConfigurator
IMediatorRegistrationContext
IMessageCorrelationId`1
IMissingInstanceRedeliveryConfigurator`2
IOutboxConfigurator
IPartitioner
IPartitioner`1
IPipeConnectorSpecification
IReceiveEndpointConnector
IReceiveEndpointConnector`1
IRedeliveryConfigurator
IRegistrationBusFactory
IRegistrationConfigurator
IRegistrationContext
Registration contains the consumers and sagas that have been registered, allowing them to be configured on one or more
receive endpoints.
IRescueConfigurator`2
IRetryConfigurator
IRiderRegistrationConfigurator
IRiderRegistrationConfigurator`1
IRiderRegistrationContext
ISagaRegistrationConfigurator
ISagaRegistrationConfigurator`1
ISagaRepositoryRegistrationConfigurator`1
IScopedClientFactory
A scoped client factory
IStateMachineActivitySelector`1
IStateMachineActivitySelector`2
IStateMachineEventActivitiesBuilder`1
IStateMachineFaultedActivitySelector`2
IStateMachineFaultedActivitySelector`3
IStateMachineModifier`1
ITimeoutConfigurator
ITransactionConfigurator
ITransformConfigurator`1
ITransformSpecificationConfigurator`1
PipeContextHandle`1
A handle to a PipeContext instance (of type ), which can be disposed
once it is no longer needed (or can no longer be used).
TransactionContext