MassTransit
Namespace with 258 public types
Classes
CommandException
ConfigurationException
ConsumerException
ConsumerMessageException
ContextException
ControlEndpointDefinition
Specifies a temporary endpoint, with the prefix "response"
ConventionException
EndpointConventionCache`1
A cache of convention-based CorrelationId mappers, used unless overridden by some mystical force
EndpointException
EndpointNotFoundException
JobAlreadyExistsException
JobNotFoundException
ManagementEndpointDefinition
Specifies a management endpoint, with the prefix "manage"
MassTransitBus
MassTransitException
MessageDataException
MessageDataNotFoundException
MessageException
MessageInitializerException
MessageRequestClient`2
Implements a request client that uses specified endpoint to send the request and return the
response task.
MessageRequestClientFactory`2
MessageRetryLimitExceededException
MessageUrn
NotImplementedByDesignException
PipeFactoryException
PipelineException
PublishException
PublishRequestClient`2
Implements a request client that allows a message to be published, versus sending to a specific endpoint
RequestCanceledException
RequestException
RequestFaultException
RequestTimeoutException
ResponseEndpointDefinition
Specifies a temporary endpoint, with the prefix "response"
SagaException
SendException
ShutDownException
TemporaryEndpointDefinition
Specifies a temporary endpoint, with the prefix "response"
TransportException
TransportUnavailableException
TurnoutEndpointDefinition
Specifies a turnout endpoint, with the prefix "response"
Structures
RequestTimeout
A timeout, which can be a default (none) or a valid TimeSpan > 0, includes factory methods to make it "cute"
Enumerations
BatchCompletionMode
The reason this batch was made ready for consumption
Static Classes
AuditConfigurationExtensions
BatchConsumerExtensions
Bus
used to get access to the bus factories
BusControlExtensions
BusFactoryExtensions
BusHandleExtensions
BusObserverExtensions
CancelScheduledSendExtensions
ClientFactoryExtensions
ConcurrentMessageLimitExtensions
ConfigurationProviderExtensions
ConsumeContextExtensions
ConsumeContextSchedulerExtensions
ConsumeContextSelfSchedulerExtensions
ConsumerConvention
Used to register conventions for consumer message types
ConsumerExtensions
Consumes`1
API-oriented class.
CorrelationIdConventionExtensions
CourierHostConfiguratorExtensions
CryptoStreamProviderExtensions
DeadLetterExtensions
DelegatePipeConfiguratorExtensions
DeserializeVariableExtensions
DiagnosticHeaders
DiagnosticsActivityPipeConfiguratorExtensions
EndpointConvention
EndpointConventionCache
EndpointConventionExtensions
FilterConfiguratorExtensions
HandlerExtensions
HostConnectReceiveEndpointExtensions
InMemoryBus
InMemoryConfigurationExtensions
InMemoryHostRequestClientExtensions
InMemoryOutboxConfiguratorExtensions
InstanceExtensions
Extensions for subscribing object instances.
InVar
Variables, which can be used for message initialization
MessageDataConfiguratorExtensions
MessageDataExtensions
MessageHeaders
MessageInitializerExtensions
MessageRetryConfigurationExtensions
MessageSchedulerExtensions
ObserverExtensions
PipeExtensions
ProbeContextExtensions
PublishContextExecuteExtensions
PublishEndpointRecurringSchedulerExtensions
PublishEndpointSchedulerExtensions
ReceiveEndpointConfigurationExtensions
ReceiveTransportObserverExtensions
RedeliverExtensions
RegistrationExtensions
RequestClientExtensions
RequestExtensions
RespondAsyncExecuteExtensions
Retry
RetryContextExtensions
RoutingSlipEventCorrelationExtensions
SagaExtensions
SagaFilterExtensions
SagaPipeConfiguratorExtensions
ScheduledRedeliveryConfigurationExtensions
ScheduledRetryExtensions
ScheduleMessageExtensions
Extensions for scheduling publish/send message
ScheduleRecurringMessageExtensions
SendContextExecuteExtensions
SendContextExtensions
SendEndpointExtensions
SendEndpointRecurringSchedulerExtensions
SendEndpointSchedulerExtensions
SerializerConfigurationExtensions
TimeSpanContextScheduleExtensions
TimeSpanScheduleExtensions
TransactionConfiguratorExtensions
TransactionContextExtensions
TransformConfiguratorExtensions
TurnoutConfigurationExtensions
TurnoutEventExtensions
Abstract Classes
AbstractUriException
Interfaces
Batch`1
A batch of messages which are delivered to a consumer all at once
BusHandle
Returned once a bus has been started. Should call Stop or Dispose before the process
can exit.
BusReady
ConsumeContext
ConsumeContext`1
ConsumerConsumeContext`1
ConsumerConsumeContext`2
A consumer and consume context mixed together, carrying both a consumer and the message
consume context.
CorrelatedBy`1
Used to identify a message as correlated so that the CorrelationId can be returned
ExceptionConsumeContext
ExceptionConsumeContext`1
ExceptionConsumerConsumeContext`1
ExceptionInfo
An exception information that is serializable
ExceptionReceiveContext
ExceptionSagaConsumeContext`1
Fault
Published (or sent, if part of a request/response conversation) when a fault occurs during message
processing
Fault`1
A faulted message, published when a message consumer fails to process the message
Headers
Headers are used to store value outside of a message body that are transported with
the message content.
HostInfo
The host where an event or otherwise was produced
a routing slip
HostReady
HostReceiveEndpointHandle
Returned when a receive endpoint is added to a host
IActivityRegistrationConfigurator`3
IBus
A bus is a logical element that includes a local endpoint and zero or more receive endpoints
IBusControl
IBusFactory
IBusFactoryConfigurator
IBusFactorySelector
Use one of the selector extension methods to create a bus instance for the
selected transport.
IBusObserver
Used to observe events produced by the bus
IClientFactory
A client factory supports the creation of smart clients that use the
smart endpoint aspects of Conductor to intelligently route messages.
ICompensateActivityConfigurator`2
Configure the execution of the activity and arguments with some tasty middleware.
ICompensateActivityLogConfigurator`1
Configure the execution of the activity and arguments with some tasty middleware.
IConsumeMessageObserver`1
Intercepts the ConsumeContext
IConsumeObserver
Intercepts the ConsumeContext
IConsumePipeConfigurator
IConsumer
Marker interface used to assist identification in IoC containers.
Not to be used directly as it does not contain the message type of the
consumer
IConsumer`1
Defines a class that is a consumer of a message. The message is wrapped in an IConsumeContext
interface to allow access to details surrounding the inbound message, including headers.
IConsumerConvention
A consumer convention is used to find message types inside a consumer class.
IConsumerFactory`1
Maps an instance of a consumer to one or more Consume methods for the specified message type
The whole purpose for this interface is to allow the creator of the consumer to manage the lifecycle
of the consumer, along with anything else that needs to be managed by the factory, container, etc.
IConsumerMessageConvention
A convention that returns connectors for message types that are defined in the consumer
type.
IConsumerRegistrationConfigurator`1
IConsumerTestFactorySelector`1
IConsumeTransformSpecification`1
IEndpointConventionCache`1
IEndpointDefinition
Defines an endpoint in a transport-independent way
IEndpointDefinition`1
IEndpointNameFormatter
IExecuteActivityArgumentsConfigurator`1
Configure the execution of the activity and arguments with some tasty middleware.
IExecuteActivityConfigurator`2
Configure the execution of the activity and arguments with some tasty middleware.
IExecuteActivityRegistrationConfigurator`2
IFault
IHost
A Bus Host is a transport-neutral reference to a host
IInMemoryBusFactoryConfigurator
IInMemoryReceiveEndpointConfigurator
IManagementEndpointConfigurator
Used to configure the management endpoint, and to denote the configurator as for that
purpose to be usable by middleware components wanting to connect to it.
IMessageConsumer`1
Defines a class as a consumer of messages which implement T, either as a class or interface
IMessageData
IMessageDeserializer
IMessageFilterConfigurator
Configures a message filter, for including and excluding message types
IMessageInterfaceType
IMessageScheduler
A message scheduler is able to schedule a message for delivery.
IMessageSerializer
A message serializer is responsible for serializing a message. Shocking, I know.
IPublishConvention
IPublishEndpoint
A publish endpoint lets the underlying transport determine the actual endpoint to which
the message is sent. For example, an exchange on RabbitMQ and a topic on Azure Service bus.
IPublishEndpointProvider
IPublishMessageObserver`1
Observes messages as they are published via a publish endpoint. These should not be used to intercept or
filter messages, in that case a filter should be created and registered on the transport.
IPublishObserver
Observes messages as they are published via a publish endpoint. These should not be used to intercept or
filter messages, in that case a filter should be created and registered on the transport.
IPublishObserverConnector
Connect an observer that is notified when a message is sent to an endpoint
IPublishPipeConfigurator
IPublishPipelineConfigurator
IPublishTransformSpecification`1
IPublishTransportProvider
IReceiveEndpoint
A service endpoint has a inbound transport that pushes messages to consumers
IReceiveEndpointBuilder
IReceiveEndpointConfigurator
Configure a receiving endpoint
IReceiveEndpointControl
IReceiveEndpointObserver
Used to observe the events signaled by a receive endpoint
IReceiveEndpointSpecification
Specification for configuring a receive endpoint
IReceiveObserver
An observer that can monitor a receive endpoint to track message consumption at the
endpoint level.
IReceivePipeConfigurator
IReceivePipelineConfigurator
IReceiveTransportObserver
Used to observe the events signaled by a receive endpoint
IRecurringMessageScheduler
A message scheduler is able to schedule a message for delivery.
IRegistration
Registration contains the consumers and sagas that have been registered, allowing them to be configured on one or more
receive endpoints.
IRegistrationConfigurator
IRequestClient`1
A request client, which is used to send a request, as well as get one or more response types from that request.
IRequestClient`2
The legacy request client interface, which combines the request and response type into a single interface. This will eventually
be marked obsolete.
IRequestClientFactory`2
A request client factory which is unique to each consume, but uses a return path specified
by the creation of the factory
IRescueConfigurator
ISagaConfigurator`1
ISagaMessageConfigurator`1
ISagaMessageConfigurator`2
ISagaMessageSpecification`1
ISagaMessageSpecification`2
ISagaRegistrationConfigurator`1
ISagaSpecification`1
A consumer specification, that can be modified
ISendEndpoint
ISendEndpointProvider
The Send Endpoint Provider is used to retrieve endpoints using addresses. The interface is
available both at the bus and within the context of most message receive handlers, including
the consume context, saga context, consumer context, etc. The most local provider should be
used to ensure message continuity is maintained.
ISendMessageObserver`1
Observes messages as they are sent to transports. These should not be used to intercept or
filter messages, in that case a filter should be created and registered on the transport.
ISendObserver
Observes messages as they are sent to transports. These should not be used to intercept or
filter messages, in that case a filter should be created and registered on the transport.
ISendObserverConnector
Connect an observer that is notified when a message is sent to an endpoint
ISendPipeConfigurator
ISendPipelineConfigurator
ISendTransformSpecification`1
ISendTransportProvider
ITransactionConfigurator
ITransformConfigurator`1
MessageContext
The message context includes the headers that are transferred with the message
MessageData`1
A big property is a message property that is stored outside the message transport
MessageRedeliveryContext
Used to reschedule delivery of the current message
MessageSchedulerContext
PublishContext
PublishContext`1
ReceiveContext
The receive context is sent from the transport when a message is ready to be processed
from the transport.
ReceiveEndpointCompleted
ReceiveEndpointEvent
ReceiveEndpointFaulted
ReceiveEndpointReady
ReceiveFault
Published when a message fails to deserialize at the endpoint
ReceiveTransportCompleted
ReceiveTransportEvent
ReceiveTransportFaulted
ReceiveTransportReady
Request`1
A sent request, that may be in-process until the request task is completed
RequestHandle
RequestHandle`1
A request handle manages the client-side request, and allows the request to be configured, response types added, etc. The handle
should be disposed once it is no longer in-use, and the request has been completed (successfully, or otherwise).
Response`1
A request's response, which is of the specified type
SagaConsumeContext`1
Consume context including the saga instance consuming the message. Note
this does not expose the message type, for filters that do not care about message type.
SagaConsumeContext`2
Consume context including the saga instance consuming the message
SendContext
Unlike the old world, the send context is returned from the endpoint and used to configure the message sending.
That way the message is captured by the endpoint and then any configuration is done at the higher level.
SendContext`1
The SendContext is used to tweak the send to the endpoint
SendHeaders
TransactionContext