MessageHandler MH Sign Up

IPumpMessages Interface



Package: MessageHandler.Runtime.AtomicProcessing.Receiving
Assembly: MessageHandler.Runtime.AtomicProcessing.Receiving
Namespace: MessageHandler.Runtime.AtomicProcessing

An interface to be implement by class that pump messages into the pipeline.


Property Description
PumpSettings Gets or sets the settings for this pump.


Method Description
OnMessage(Func<MessageContext,Task>) Callback to call whenever a new message arrives.
OnError(Func<RecoveryContext,Task>) Callback to call whenever a message cannot be processed.
OnCompletion(Func) Callback to call whenever a message gets completed after processing.
Start(CancellationToken) Starts the pump, until cancellation is requested.
Stop() Stop the pump.

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.