Definition
Package: MessageHandler.Runtime.StreamProcessing
Assembly: MessageHandler.Runtime.StreamProcessing
Namespace: MessageHandler.Runtime.StreamProcessing
Extension methods which allow configuration of the stream processing pipeline
Methods
| Method | Description |
|---|---|
| StreamProcessingPipeline(this HandlerRuntimeConfiguration, Action |
Set up a stream processing pipeline |
| StreamProcessingPipeline(this HandlerRuntimeConfiguration, string, Action |
Set up a stream processing pipeline |
| DisruptorRingSize(this StreamProcessingPipelineConfiguration, int) | Configures the size of the ringbuffer used for switching between IO and processing threads |