Definition
Package: MessageHandler.Runtime.AtomicProcessing.Receiving.InMemory
Assembly: MessageHandler.Runtime.AtomicProcessing.Receiving.InMemory
Namespace: MessageHandler.Runtime.AtomicProcessing
A message pump to pump messages from memory
Properties
Property | Description |
---|---|
PumpSettings | Gets or sets the settings of the pump |
Methods
Method | Description |
---|---|
OnMessage(Func<MessageContext,Task>) | Callback to call whenever a new message arrives. |
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. |