System.Cloud.Messaging Namespace

Classes

AsyncProcessingPipelineBuilderExtensions	Provides extension methods for IAsyncProcessingPipelineBuilder to register: singletons, IMessageSource, IMessageDestination, IMessageMiddleware, MessageDelegate, MessageConsumer.
BaseMessageConsumer	Reference base class implementation for IMessageConsumer.
DefaultMessageConsumer	Provides default implementation to MessageConsumer.
LatencyRecorderMiddlewareExtensions	Provides extension methods for IAsyncProcessingPipelineBuilder to add support for the IMessageMiddleware implementation to record latency.
MessageCancelledTokenFeatureExtensions	Extension methods for MessageContext for setting/retrieving CancellationTokenSource.
MessageCompleteActionFeatureExtensions	Extension methods for MessageContext for IMessageCompleteActionFeature.
MessageConsumer	Base class implementation for consuming and processing messages.
MessageContext	Represents the context for storing different Features required for the processing of message(s).
MessageDestinationFeatureExtensions	Extension methods for MessageContext to be used for IMessageDestination.
MessageDestinationPayloadFeatureExtensions	Extension methods for MessageContext for writing IMessagePayloadFeature to a IMessageDestination messages.
MessageLatencyContextFeatureExtensions	Provides extension methods for MessageContext class to add support for setting/retrieving Microsoft.Extensions.Telemetry.Latency.ILatencyContext.
MessagePostponeActionFeatureExtensions	Extension methods for MessageContext for IMessagePostponeActionFeature.
MessagePostponeFeatureExtensions	Provides extension methods for MessageContext class to add support for IMessagePostponeFeature.
MessageSourceFeatureExtensions	Extension methods for MessageContext used during IMessageSource for IMessageSourceFeatures.
MessageSourcePayloadFeatureExtensions	Extension methods for MessageContext obtained from IMessageSource for IMessagePayloadFeature.
MessageVisibilityDelayFeatureExtensions	Provides extension methods for MessageContext to add support for IMessageVisibilityDelayFeature.
SerializedMessagePayloadFeatureExtensions	Provides extension methods for MessageContext class to add support for ISerializedMessagePayloadFeature<T>.
ServiceCollectionExtensions	Extension methods for IServiceCollection to create async processing pipeline.
ServiceProviderExtensions	Provides extension methods to IServiceProvider to get IMessageSource, IReadOnlyList<T> and MessageDelegate.

Interfaces

IAsyncProcessingPipelineBuilder	Interface to register services for the async processing pipeline.
IMessageCompleteActionFeature	Feature interface for marking the message processing as complete.
IMessageConsumer	Interface for consuming and processing messages.
IMessageDelegate	The message delegate called by IMessageMiddleware to continue processing the message in the pipeline chain.
IMessageDestination	Interface for writing message to a destination.
IMessageDestinationFeatures	Interface for MessageContext features used for writing messages to IMessageDestination.
IMessageMiddleware	Interface for a middleware that uses MessageContext and the next MessageDelegate in the pipeline to process the message.
IMessagePayloadFeature	Feature interface for setting/retrieving the message payload.
IMessagePostponeActionFeature	Feature interface for postponing the message processing.
IMessagePostponeFeature	Feature interface for postponing the message processing.
IMessageSource	Interface for a message source.
IMessageSourceFeatures	Interface for MessageContext features read from IMessageSource.
IMessageVisibilityDelayFeature	Feature interface for setting/retrieving the visibility delay.
IPipelineDelegateFactory	Factory interface for obtaining a composable IMessageDelegate from the registered pipeline of IMessageMiddleware and a terminal IMessageDelegate types which can act on the messages from IMessageConsumer.
ISerializedMessagePayloadFeature<T>	Feature interface for setting/retrieving the serialized message payload.

Delegates

MessageDelegate

The message delegate called by IMessageMiddleware to continue processing the message in the pipeline chain.