Interface IMessageSendingOperations<D>
Operations for sending messages to a destination.
Namespace: Steeltoe.Messaging.Core
Assembly: Steeltoe.Messaging.Abstractions.dll
Syntax
public interface IMessageSendingOperations<D>Type Parameters
| Name | Description |
|---|---|
| D | the type of the destination |
Methods
| Edit this page View SourceConvertAndSend(D, Object)
Convert the given object to serialized form, possibly using a message converter, wrap it as a message and send it to a specified destination.
Declaration
void ConvertAndSend(D destination, object payload)Parameters
| Type | Name | Description |
|---|---|---|
| D | destination | the target destination |
| System.Object | payload | the payload to send |
ConvertAndSend(D, Object, IDictionary<String, Object>)
Convert the given object to serialized form, possibly using a message converter, wrap it as a message with the provided headers, and send it to a specified destination.
Declaration
void ConvertAndSend(D destination, object payload, IDictionary<string, object> headers)Parameters
| Type | Name | Description |
|---|---|---|
| D | destination | the target destination |
| System.Object | payload | the payload to send |
| IDictionary<System.String, System.Object> | headers | the headers to send |
ConvertAndSend(D, Object, IDictionary<String, Object>, IMessagePostProcessor)
Convert the given object to serialized form, possibly using a message converter, wrap it as a message, with the provided headers, apply the psot processor, and send it to the specified destination.
Declaration
void ConvertAndSend(D destination, object payload, IDictionary<string, object> headers, IMessagePostProcessor postProcessor)Parameters
| Type | Name | Description |
|---|---|---|
| D | destination | the target destination |
| System.Object | payload | the payload to send |
| IDictionary<System.String, System.Object> | headers | the headers to send |
| IMessagePostProcessor | postProcessor | the post processor to apply |
ConvertAndSend(D, Object, IMessagePostProcessor)
Convert the given object to serialized form, possibly using a message converter, wrap it as a message, apply the psot processor, and send it to the specified destination.
Declaration
void ConvertAndSend(D destination, object payload, IMessagePostProcessor postProcessor)Parameters
| Type | Name | Description |
|---|---|---|
| D | destination | the target destination |
| System.Object | payload | the payload to send |
| IMessagePostProcessor | postProcessor | the post processor to apply |
ConvertAndSend(Object)
Convert the given object to serialized form, possibly using a message converter, wrap it as a message and send it to a default destination.
Declaration
void ConvertAndSend(object payload)Parameters
| Type | Name | Description |
|---|---|---|
| System.Object | payload | the payload to send |
ConvertAndSend(Object, IMessagePostProcessor)
Convert the given object to serialized form, possibly using a message converter, wrap it as a message, apply the psot processor, and send it to the default destination.
Declaration
void ConvertAndSend(object payload, IMessagePostProcessor postProcessor)Parameters
| Type | Name | Description |
|---|---|---|
| System.Object | payload | the payload to send |
| IMessagePostProcessor | postProcessor | the post processor to apply |
ConvertAndSendAsync(D, Object, CancellationToken)
Convert the given object to serialized form, possibly using a message converter, wrap it as a message and send it to a specified destination.
Declaration
Task ConvertAndSendAsync(D destination, object payload, CancellationToken cancellationToken = null)Parameters
| Type | Name | Description |
|---|---|---|
| D | destination | the target destination |
| System.Object | payload | the payload to send |
| CancellationToken | cancellationToken | token used to signal cancelation |
Returns
| Type | Description |
|---|---|
| Task | a task to signal completion |
ConvertAndSendAsync(D, Object, IDictionary<String, Object>, CancellationToken)
Convert the given object to serialized form, possibly using a message converter, wrap it as a message with the provided headers, and send it to a specified destination.
Declaration
Task ConvertAndSendAsync(D destination, object payload, IDictionary<string, object> headers, CancellationToken cancellationToken = null)Parameters
| Type | Name | Description |
|---|---|---|
| D | destination | the target destination |
| System.Object | payload | the payload to send |
| IDictionary<System.String, System.Object> | headers | the headers to send |
| CancellationToken | cancellationToken | token used to signal cancelation |
Returns
| Type | Description |
|---|---|
| Task | a task to signal completion |
ConvertAndSendAsync(D, Object, IDictionary<String, Object>, IMessagePostProcessor, CancellationToken)
Convert the given object to serialized form, possibly using a message converter, wrap it as a message, with the provided headers, apply the psot processor, and send it to the specified destination.
Declaration
Task ConvertAndSendAsync(D destination, object payload, IDictionary<string, object> headers, IMessagePostProcessor postProcessor, CancellationToken cancellationToken = null)Parameters
| Type | Name | Description |
|---|---|---|
| D | destination | the target destination |
| System.Object | payload | the payload to send |
| IDictionary<System.String, System.Object> | headers | the headers to send |
| IMessagePostProcessor | postProcessor | the post processor to apply |
| CancellationToken | cancellationToken | token used to signal cancelation |
Returns
| Type | Description |
|---|---|
| Task | a task to signal completion |
ConvertAndSendAsync(D, Object, IMessagePostProcessor, CancellationToken)
Convert the given object to serialized form, possibly using a message converter, wrap it as a message, apply the psot processor, and send it to the specified destination.
Declaration
Task ConvertAndSendAsync(D destination, object payload, IMessagePostProcessor postProcessor, CancellationToken cancellationToken = null)Parameters
| Type | Name | Description |
|---|---|---|
| D | destination | the target destination |
| System.Object | payload | the payload to send |
| IMessagePostProcessor | postProcessor | the post processor to apply |
| CancellationToken | cancellationToken | token used to signal cancelation |
Returns
| Type | Description |
|---|---|
| Task | a task to signal completion |
ConvertAndSendAsync(Object, CancellationToken)
Convert the given object to serialized form, possibly using a message converter, wrap it as a message and send it to a default destination.
Declaration
Task ConvertAndSendAsync(object payload, CancellationToken cancellationToken = null)Parameters
| Type | Name | Description |
|---|---|---|
| System.Object | payload | the payload to send |
| CancellationToken | cancellationToken | token used to signal cancelation |
Returns
| Type | Description |
|---|---|
| Task | a task to signal completion |
ConvertAndSendAsync(Object, IMessagePostProcessor, CancellationToken)
Convert the given object to serialized form, possibly using a message converter, wrap it as a message, apply the psot processor, and send it to the default destination.
Declaration
Task ConvertAndSendAsync(object payload, IMessagePostProcessor postProcessor, CancellationToken cancellationToken = null)Parameters
| Type | Name | Description |
|---|---|---|
| System.Object | payload | the payload to send |
| IMessagePostProcessor | postProcessor | the post processor to apply |
| CancellationToken | cancellationToken | token used to signal cancelation |
Returns
| Type | Description |
|---|---|
| Task | a task to signal completion |
Send(D, IMessage)
Send a message to the given destination.
Declaration
void Send(D destination, IMessage message)Parameters
| Type | Name | Description |
|---|---|---|
| D | destination | the target destination |
| IMessage | message | the message to send |
Send(IMessage)
Send a message to a default destination.
Declaration
void Send(IMessage message)Parameters
| Type | Name | Description |
|---|---|---|
| IMessage | message | the message to send |
SendAsync(D, IMessage, CancellationToken)
Send a message to the given destination.
Declaration
Task SendAsync(D destination, IMessage message, CancellationToken cancellationToken = null)Parameters
| Type | Name | Description |
|---|---|---|
| D | destination | the target destination |
| IMessage | message | the message to send |
| CancellationToken | cancellationToken | token used to signal cancelation |
Returns
| Type | Description |
|---|---|
| Task | a task to signal completion |
SendAsync(IMessage, CancellationToken)
Send a message to a default destination.
Declaration
Task SendAsync(IMessage message, CancellationToken cancellationToken = null)Parameters
| Type | Name | Description |
|---|---|---|
| IMessage | message | the message to send |
| CancellationToken | cancellationToken | token used to signal cancelation |
Returns
| Type | Description |
|---|---|
| Task | a task to signal completion |