Definition
Package: MessageHandler.Runtime.StreamProcessing.Pipeline.Reactive
Assembly: MessageHandler.Runtime.StreamProcessing.Pipeline.Reactive
Namespace: MessageHandler.Runtime.StreamProcessing
Class: ReactiveProcessing
Overloads
Method | Description |
---|---|
InterpretMessagesUsing |
Interpret the stream of messages using the provided standing query |
InterpretMessagesUsing |
Interpret the stream of messages using the provided standing query |
InterpretMessagesUsing(this ReactiveProcessingConfiguration)
Interpret the stream of messages using the provided standing query
Parameters
configuration: MessageHandler.Runtime.StreamProcessing.ReactiveProcessingConfiguration
The reactive processing configuration
Returns
MessageHandler.Runtime.StreamProcessing.ReactiveProcessingConfiguration
InterpretMessagesUsing(this ReactiveProcessingConfiguration, T)
Interpret the stream of messages using the provided standing query
Parameters
configuration: MessageHandler.Runtime.StreamProcessing.ReactiveProcessingConfiguration
The reactive processing configuration
query: T
And instance of a standing query builder
Returns
MessageHandler.Runtime.StreamProcessing.ReactiveProcessingConfiguration