Edit

Share via

IAsyncProcessingPipelineBuilder Interface

  • Reference

Definition

Namespace:
System.Cloud.Messaging
Assemblies:
System.Cloud.Messaging.dll, System.Cloud.Messaging.Abstractions.dll
Assembly:
System.Cloud.Messaging.Abstractions.dll
Packages:
System.Cloud.Messaging v8.0.0-rc.1.23453.1, System.Cloud.Messaging.Abstractions v8.0.0-preview.4.23273.7
Package:
System.Cloud.Messaging.Abstractions v8.0.0-preview.4.23273.7

Interface to register services for the async processing pipeline.

public interface class IAsyncProcessingPipelineBuilder
public interface IAsyncProcessingPipelineBuilder
type IAsyncProcessingPipelineBuilder = interface
Public Interface IAsyncProcessingPipelineBuilder

Properties

PipelineName

Gets the name of the message pipeline.
Services

Gets the IServiceCollection.

Extension Methods

AddKeyedSingleton<T>(IAsyncProcessingPipelineBuilder, Func<IServiceProvider,T>)

Adds any singletons required for the async processing pipeline with the provided implementationFactory.
AddKeyedSingleton<T>(IAsyncProcessingPipelineBuilder, String, Func<IServiceProvider,T>)

Adds any singletons required for the async processing pipeline with the provided implementationFactory against the provided name.
AddKeyedSingleton<T>(IAsyncProcessingPipelineBuilder)

Adds any singletons required for the async processing pipeline.
AddMessageMiddleware<TMiddleware>(IAsyncProcessingPipelineBuilder, Func<IServiceProvider,TMiddleware>)

Adds the IMessageMiddleware to the async processing pipeline with the provided implementation factory.
AddMessageMiddleware<TMiddleware>(IAsyncProcessingPipelineBuilder)

Adds the IMessageMiddleware to the async processing pipeline.
AddNamedSingleton<T>(IAsyncProcessingPipelineBuilder, Func<IServiceProvider,T>)

Add any singletons required with the provided implementationFactory.
AddNamedSingleton<T>(IAsyncProcessingPipelineBuilder, String, Func<IServiceProvider,T>)

Add any singletons required with the provided implementationFactory against the pipelineName.
AddNamedSingleton<T>(IAsyncProcessingPipelineBuilder)

Register any singletons required against the PipelineName.
ConfigureMessageConsumer<TConsumer>(IAsyncProcessingPipelineBuilder, Func<IServiceProvider,TConsumer>)

Configures the MessageConsumer for the async processing pipeline with the provided implementation factory.
ConfigureMessageConsumer<TConsumer>(IAsyncProcessingPipelineBuilder)

Configures the MessageConsumer for the async processing pipeline.
ConfigureMessageDestination<TDestination>(IAsyncProcessingPipelineBuilder, Func<IServiceProvider,TDestination>)

Configures the IMessageDestination for the async processing pipeline with the provided implementation factory.
ConfigureMessageDestination<TDestination>(IAsyncProcessingPipelineBuilder, String, Func<IServiceProvider,TDestination>)

Configures the IMessageDestination for the async processing pipeline with the provided name and implementation factory.
ConfigureMessageDestination<TDestination>(IAsyncProcessingPipelineBuilder)

Configures the IMessageDestination for the async processing pipeline.
ConfigureMessageSource<TSource>(IAsyncProcessingPipelineBuilder, Func<IServiceProvider,TSource>)

Configures the IMessageSource for the async processing pipeline with the provided implementation factory.
ConfigureMessageSource<TSource>(IAsyncProcessingPipelineBuilder)

Configures the IMessageSource for the async processing pipeline.
ConfigureTerminalMessageDelegate(IAsyncProcessingPipelineBuilder, Func<IServiceProvider,MessageDelegate>)

Configures the terminal MessageDelegate for the async processing pipeline with the provided implementation factory.
ConfigureTerminalMessageDelegate(IAsyncProcessingPipelineBuilder)

Configures the terminal MessageDelegate for the async processing pipeline.
ConfigureTerminalMessageDelegate<TDelegate>(IAsyncProcessingPipelineBuilder, Func<IServiceProvider,TDelegate>)

Configures the terminal IMessageDelegate with TDelegate implementation to the IMessageMiddleware pipeline.
ConfigureTerminalMessageDelegate<TDelegate>(IAsyncProcessingPipelineBuilder)

Configures the terminal IMessageDelegate with TDelegate implementation to the IMessageMiddleware pipeline.
RunConsumerAsBackgroundService(IAsyncProcessingPipelineBuilder)

Configures the previously registered MessageConsumer for the async processing pipeline as a BackgroundService.
AddLatencyContextMiddleware(IAsyncProcessingPipelineBuilder)

Adds the IMessageMiddleware to register the Microsoft.Extensions.Telemetry.Latency.ILatencyContextProvider in IMessageMiddleware pipeline to create and set Microsoft.Extensions.Telemetry.Latency.ILatencyContext with the MessageContext.
AddLatencyContextMiddleware<T>(IAsyncProcessingPipelineBuilder, Func<IServiceProvider,T>, Func<IServiceProvider,IEnumerable<ILatencyDataExporter>>)

Adds the IMessageMiddleware to register the provided Microsoft.Extensions.Telemetry.Latency.ILatencyContextProvider in the IMessageMiddleware pipeline to create and set Microsoft.Extensions.Telemetry.Latency.ILatencyContext with the MessageContext.
AddLatencyContextMiddleware<T>(IAsyncProcessingPipelineBuilder, Func<IServiceProvider,T>)

Adds the IMessageMiddleware to reuse the existing Microsoft.Extensions.Telemetry.Latency.ILatencyContext registered with the ASP.NET pipeline and set it in the MessageContext.
AddLatencyRecorderMessageMiddleware(IAsyncProcessingPipelineBuilder, MeasureToken, MeasureToken)

Adds the IMessageMiddleware for recording latency of the underlying IMessageMiddleware pipeline by obtaining the Microsoft.Extensions.Telemetry.Latency.ILatencyContext associated with MessageContext.

Applies to