MessageHandler MH Sign Up

InMemoryPump Class



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

A message pump to pump messages from memory


Property Description
PumpSettings Gets or sets the settings of the pump


Method Description
OnMessage(Func<MessageContext,Task>) Callback to call whenever a new message arrives.
OnError(Func<RecoveryContext,Task>) Callback to call whenever a new message fails to process.
OnCompletion(Func) Callback to call whenever a message gets completed after processing.
Receive(string, Dictionary<string,string>) Receive a message
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.