Definition
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.
Properties
| Property | Description |
|---|---|
| PumpSettings | Gets or sets the settings for this pump. |
Methods
| 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. |