Definition
Package: MessageHandler.Runtime.StreamProcessing.Pipeline.Reactive
Assembly: MessageHandler.Runtime.StreamProcessing.Pipeline.Reactive
Namespace: MessageHandler.Runtime.StreamProcessing
Extension methods which allow to configure the runtime for reactive stream processing
Methods
Method | Description |
---|---|
EnableReactiveProcessing(this PipelineConfiguration, Action |
Enable reactive processing |
InterpretMessagesUsing |
Interpret the stream of messages using the provided standing query |
InterpretMessagesUsing |
Interpret the stream of messages using the provided standing query |
RespondUsing |
Respond to messages returned by the standing query |
RespondUsing |
Respond to messages returned by the standing query |
CompleteBatchesWith |
Complete batches with the given batch completion logic |
CompleteBatchesWith |
Complete batches with the given batch completion logic |