Interface IMessageSendingOperations<D>
Operations for sending messages to a destination.
[Obsolete("This feature will be removed in the next major version. See https://steeltoe.io/docs/v3/obsolete for details.")]
public interface IMessageSendingOperations<D>
Type Parameters
Dthe type of the destination
Methods
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.
void ConvertAndSend(object payload)
Parameters
payloadobjectthe 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.
void ConvertAndSend(object payload, IMessagePostProcessor postProcessor)
Parameters
payloadobjectthe payload to send
postProcessorIMessagePostProcessorthe post processor to apply
ConvertAndSend(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.
void ConvertAndSend(D destination, object payload)
Parameters
destinationDthe target destination
payloadobjectthe payload to send
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.
void ConvertAndSend(D destination, object payload, IMessagePostProcessor postProcessor)
Parameters
destinationDthe target destination
payloadobjectthe payload to send
postProcessorIMessagePostProcessorthe post processor to apply
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.
void ConvertAndSend(D destination, object payload, IDictionary<string, object> headers)
Parameters
destinationDthe target destination
payloadobjectthe payload to send
headersIDictionary<string, object>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.
void ConvertAndSend(D destination, object payload, IDictionary<string, object> headers, IMessagePostProcessor postProcessor)
Parameters
destinationDthe target destination
payloadobjectthe payload to send
headersIDictionary<string, object>the headers to send
postProcessorIMessagePostProcessorthe post processor to apply
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.
Task ConvertAndSendAsync(object payload, IMessagePostProcessor postProcessor, CancellationToken cancellationToken = default)
Parameters
payloadobjectthe payload to send
postProcessorIMessagePostProcessorthe post processor to apply
cancellationTokenCancellationTokentoken used to signal cancelation
Returns
- 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.
Task ConvertAndSendAsync(object payload, CancellationToken cancellationToken = default)
Parameters
payloadobjectthe payload to send
cancellationTokenCancellationTokentoken used to signal cancelation
Returns
- 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.
Task ConvertAndSendAsync(D destination, object payload, IMessagePostProcessor postProcessor, CancellationToken cancellationToken = default)
Parameters
destinationDthe target destination
payloadobjectthe payload to send
postProcessorIMessagePostProcessorthe post processor to apply
cancellationTokenCancellationTokentoken used to signal cancelation
Returns
- 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.
Task ConvertAndSendAsync(D destination, object payload, IDictionary<string, object> headers, IMessagePostProcessor postProcessor, CancellationToken cancellationToken = default)
Parameters
destinationDthe target destination
payloadobjectthe payload to send
headersIDictionary<string, object>the headers to send
postProcessorIMessagePostProcessorthe post processor to apply
cancellationTokenCancellationTokentoken used to signal cancelation
Returns
- 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.
Task ConvertAndSendAsync(D destination, object payload, IDictionary<string, object> headers, CancellationToken cancellationToken = default)
Parameters
destinationDthe target destination
payloadobjectthe payload to send
headersIDictionary<string, object>the headers to send
cancellationTokenCancellationTokentoken used to signal cancelation
Returns
- Task
a task to signal completion
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.
Task ConvertAndSendAsync(D destination, object payload, CancellationToken cancellationToken = default)
Parameters
destinationDthe target destination
payloadobjectthe payload to send
cancellationTokenCancellationTokentoken used to signal cancelation
Returns
- Task
a task to signal completion
Send(IMessage)
Send a message to a default destination.
void Send(IMessage message)
Parameters
messageIMessagethe message to send
Send(D, IMessage)
Send a message to the given destination.
void Send(D destination, IMessage message)
Parameters
destinationDthe target destination
messageIMessagethe message to send
SendAsync(IMessage, CancellationToken)
Send a message to a default destination.
Task SendAsync(IMessage message, CancellationToken cancellationToken = default)
Parameters
messageIMessagethe message to send
cancellationTokenCancellationTokentoken used to signal cancelation
Returns
- Task
a task to signal completion
SendAsync(D, IMessage, CancellationToken)
Send a message to the given destination.
Task SendAsync(D destination, IMessage message, CancellationToken cancellationToken = default)
Parameters
destinationDthe target destination
messageIMessagethe message to send
cancellationTokenCancellationTokentoken used to signal cancelation
Returns
- Task
a task to signal completion