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 |