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