Definition
Package: MessageHandler.Runtime.AtomicProcessing.Pipeline
Assembly: MessageHandler.Runtime.AtomicProcessing.Pipeline
Namespace: MessageHandler.Runtime.AtomicProcessing
Class: IDispatchMessages
Overloads
| Method | Description |
|---|---|
| Dispatch(object) | Dispatches a message. |
| Dispatch(object, IDictionary<string,string>) | Dispatches a message with the specified headers. |
| Dispatch(object, IDictionary<string,string>, AtomicContext) | Dispatches a message with the specified headers in an atomic context. |
| Dispatch(object, IDictionary<string,string>, AtomicContext, CancellationToken) | Dispatches a message with the specified headers in an atomic context with cancellation support. |
| Dispatch(IEnumerable | Dispatches messages. |
| Dispatch(IEnumerable | Dispatches messages with the specified headers. |
| Dispatch(IEnumerable | Dispatches messages with the specified headers in an atomic context. |
| Dispatch(IEnumerable | Dispatches messages with the specified headers in an atomic context with cancellation support. |
Dispatch(object)
Dispatches a message.
Parameters
message: System.Object
The message to dispatch.
Returns
System.Threading.Tasks.Task
Dispatch(object, IDictionary<string,string>)
Dispatches a message with the specified headers.
Parameters
message: System.Object
The message to dispatch.
headers: System.Collections.Generic.IDictionary
The headers to add to the message.
Returns
System.Threading.Tasks.Task
Dispatch(object, IDictionary<string,string>, AtomicContext)
Dispatches a message with the specified headers in an atomic context.
Parameters
message: System.Object
The message to dispatch.
headers: System.Collections.Generic.IDictionary
The headers to add to the message.
AtomicContext: MessageHandler.Runtime.AtomicProcessing.AtomicContext
The atomic context to dispatch in.
Returns
System.Threading.Tasks.Task
Dispatch(object, IDictionary<string,string>, AtomicContext, CancellationToken)
Dispatches a message with the specified headers in an atomic context with cancellation support.
Parameters
message: System.Object
The message to dispatch.
headers: System.Collections.Generic.IDictionary
The headers to add to the message.
AtomicContext: MessageHandler.Runtime.AtomicProcessing.AtomicContext
The headers to add to the messages.
cancellationToken: System.Threading.CancellationToken
A cancellation token.
Returns
System.Threading.Tasks.Task
Dispatch(IEnumerable
Dispatches messages.
Parameters
messages: System.Collections.Generic.IEnumerable
The messages to dispatch.
Returns
System.Threading.Tasks.Task
Dispatch(IEnumerable
Dispatches messages with the specified headers.
Parameters
messages: System.Collections.Generic.IEnumerable
The messages to dispatch.
headers: System.Collections.Generic.IDictionary
The headers to add to the messages.
Returns
System.Threading.Tasks.Task
Dispatch(IEnumerable
Dispatches messages with the specified headers in an atomic context.
Parameters
messages: System.Collections.Generic.IEnumerable
The messages to dispatch.
headers: System.Collections.Generic.IDictionary
The headers to add to the messages.
AtomicContext: MessageHandler.Runtime.AtomicProcessing.AtomicContext
The atomic context to dispatch in.
Returns
System.Threading.Tasks.Task
Dispatch(IEnumerable
Dispatches messages with the specified headers in an atomic context with cancellation support.
Parameters
messages: System.Collections.Generic.IEnumerable
The messages to dispatch.
headers: System.Collections.Generic.IDictionary
The headers to add to the messages.
AtomicContext: MessageHandler.Runtime.AtomicProcessing.AtomicContext
The atomic context to dispatch in.
cancellationToken: System.Threading.CancellationToken
A cancellation token.
Returns
System.Threading.Tasks.Task