ReactiveProcessing Class

Last updated on 2023-10-03T20:43:26 / 2 Minutes Read

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(this ReactiveProcessingConfiguration)	Interpret the stream of messages using the provided standing query
InterpretMessagesUsing(this ReactiveProcessingConfiguration, T)	Interpret the stream of messages using the provided standing query
RespondUsing(this ReactiveProcessingConfiguration)	Respond to messages returned by the standing query
RespondUsing(this ReactiveProcessingConfiguration, T)	Respond to messages returned by the standing query
CompleteBatchesWith(this ReactiveProcessingConfiguration)	Complete batches with the given batch completion logic
CompleteBatchesWith(this ReactiveProcessingConfiguration, T)	Complete batches with the given batch completion logic

Sign up to our newsletter to get notified about new content and releases

You can unsubscribe at any time by clicking the link in the footer of your emails. I use Mailchimp as my marketing platform. By clicking subscribe, you acknowledge that your information will be transferred to Mailchimp for processing. Learn more about Mailchimp's privacy practices here.