Definition
Package: MessageHandler.Runtime.StreamProcessing.Pipeline.Reactive
Assembly: MessageHandler.Runtime.StreamProcessing.Pipeline.Reactive
Namespace: MessageHandler.Runtime.StreamProcessing
Class: ReactiveProcessing
Overloads
| Method | Description |
|---|---|
| RespondUsing |
Respond to messages returned by the standing query |
| RespondUsing |
Respond to messages returned by the standing query |
RespondUsing(this ReactiveProcessingConfiguration)
Respond to messages returned by the standing query
Parameters
configuration: MessageHandler.Runtime.StreamProcessing.ReactiveProcessingConfiguration
The reactive processing configuration
Returns
MessageHandler.Runtime.StreamProcessing.ReactiveProcessingConfiguration
RespondUsing(this ReactiveProcessingConfiguration, T)
Respond to messages returned by the standing query
Parameters
configuration: MessageHandler.Runtime.StreamProcessing.ReactiveProcessingConfiguration
The reactive processing configuration
action: T
An instance of the action type which will be run in repsonse to the queried messages
Returns
MessageHandler.Runtime.StreamProcessing.ReactiveProcessingConfiguration