Interface IDestinationResolvingMessageRequestReplyOperations<D>
Provide operations for sending and receiving messages to and from a destination specified as a string
Inherited Members
Namespace: Steeltoe.Messaging.Core
Assembly: Steeltoe.Messaging.Abstractions.dll
Syntax
public interface IDestinationResolvingMessageRequestReplyOperations<D> : IMessageRequestReplyOperations<D>
Type Parameters
Name | Description |
---|---|
D | the type of the destination |
Methods
| Edit this page View SourceConvertSendAndReceive<T>(String, Object)
Resolve the given destination name, convert the payload request object to serialized form, possibly using a message converter and then wrap it as a message and send it to the resolved destination, receive a reply and convert its body to the specified target type.
Declaration
T ConvertSendAndReceive<T>(string destinationName, object request)
Parameters
Type | Name | Description |
---|---|---|
System.String | destinationName | the name of the target destination |
System.Object | request | the payload for the request message |
Returns
Type | Description |
---|---|
T | the converted payload of the reply message, possibly null |
Type Parameters
Name | Description |
---|---|
T | the type of the reply |
ConvertSendAndReceive<T>(String, Object, IDictionary<String, Object>)
Resolve the given destination name, convert the payload request object to serialized form, possibly using a message converter and then wrap it as a message with the given headers and send it to the resolved destination, receive a reply and convert its body to the specified target type.
Declaration
T ConvertSendAndReceive<T>(string destinationName, object request, IDictionary<string, object> headers)
Parameters
Type | Name | Description |
---|---|---|
System.String | destinationName | the name of the target destination |
System.Object | request | the payload for the request message |
IDictionary<System.String, System.Object> | headers | the headers to include in the message |
Returns
Type | Description |
---|---|
T | the converted payload of the reply message, possibly null |
Type Parameters
Name | Description |
---|---|
T | the type of the reply |
ConvertSendAndReceive<T>(String, Object, IDictionary<String, Object>, IMessagePostProcessor)
Resolve the given destination name, convert the payload request object to serialized form, possibly using a message converter and then wrap it as a message with the given headers, apply the post process, and send it to the resolved destination, receive a reply and convert its body to the specified target type.
Declaration
T ConvertSendAndReceive<T>(string destinationName, object request, IDictionary<string, object> headers, IMessagePostProcessor requestPostProcessor)
Parameters
Type | Name | Description |
---|---|---|
System.String | destinationName | the name of the target destination |
System.Object | request | the payload for the request message |
IDictionary<System.String, System.Object> | headers | the headers to include in the message |
IMessagePostProcessor | requestPostProcessor | post process for the request message |
Returns
Type | Description |
---|---|
T | the converted payload of the reply message, possibly null |
Type Parameters
Name | Description |
---|---|
T | the type of the reply |
ConvertSendAndReceive<T>(String, Object, IMessagePostProcessor)
Resolve the given destination name, convert the payload request object to serialized form, possibly using a message converter and then wrap it as a message, apply the post process, and send it to the resolved destination, receive a reply and convert its body to the specified target type.
Declaration
T ConvertSendAndReceive<T>(string destinationName, object request, IMessagePostProcessor requestPostProcessor)
Parameters
Type | Name | Description |
---|---|---|
System.String | destinationName | the name of the target destination |
System.Object | request | the payload for the request message |
IMessagePostProcessor | requestPostProcessor | post process for the request message |
Returns
Type | Description |
---|---|
T | the converted payload of the reply message, possibly null |
Type Parameters
Name | Description |
---|---|
T | the type of the reply |
ConvertSendAndReceiveAsync<T>(String, Object, CancellationToken)
Resolve the given destination name, convert the payload request object to serialized form, possibly using a message converter and then wrap it as a message and send it to the resolved destination, receive a reply and convert its body to the specified target type.
Declaration
Task<T> ConvertSendAndReceiveAsync<T>(string destinationName, object request, CancellationToken cancellationToken = null)
Parameters
Type | Name | Description |
---|---|---|
System.String | destinationName | the name of the target destination |
System.Object | request | the payload for the request message |
CancellationToken | cancellationToken | token used to signal cancelation |
Returns
Type | Description |
---|---|
Task<T> | a task to signal completion |
Type Parameters
Name | Description |
---|---|
T | the type of the reply |
ConvertSendAndReceiveAsync<T>(String, Object, IDictionary<String, Object>, CancellationToken)
Resolve the given destination name, convert the payload request object to serialized form, possibly using a message converter and then wrap it as a message with the given headers and send it to the resolved destination, receive a reply and convert its body to the specified target type.
Declaration
Task<T> ConvertSendAndReceiveAsync<T>(string destinationName, object request, IDictionary<string, object> headers, CancellationToken cancellationToken = null)
Parameters
Type | Name | Description |
---|---|---|
System.String | destinationName | the name of the target destination |
System.Object | request | the payload for the request message |
IDictionary<System.String, System.Object> | headers | the headers to include in the message |
CancellationToken | cancellationToken | token used to signal cancelation |
Returns
Type | Description |
---|---|
Task<T> | a task to signal completion |
Type Parameters
Name | Description |
---|---|
T | the type of the reply |
ConvertSendAndReceiveAsync<T>(String, Object, IDictionary<String, Object>, IMessagePostProcessor, CancellationToken)
Resolve the given destination name, convert the payload request object to serialized form, possibly using a message converter and then wrap it as a message with the given headers, apply the post process, and send it to the resolved destination, receive a reply and convert its body to the specified target type.
Declaration
Task<T> ConvertSendAndReceiveAsync<T>(string destinationName, object request, IDictionary<string, object> headers, IMessagePostProcessor requestPostProcessor, CancellationToken cancellationToken = null)
Parameters
Type | Name | Description |
---|---|---|
System.String | destinationName | the name of the target destination |
System.Object | request | the payload for the request message |
IDictionary<System.String, System.Object> | headers | the headers to include in the message |
IMessagePostProcessor | requestPostProcessor | post process for the request message |
CancellationToken | cancellationToken | token used to signal cancelation |
Returns
Type | Description |
---|---|
Task<T> | a task to signal completion |
Type Parameters
Name | Description |
---|---|
T | the type of the reply |
ConvertSendAndReceiveAsync<T>(String, Object, IMessagePostProcessor, CancellationToken)
Resolve the given destination name, convert the payload request object to serialized form, possibly using a message converter and then wrap it as a message, apply the post process, and send it to the resolved destination, receive a reply and convert its body to the specified target type.
Declaration
Task<T> ConvertSendAndReceiveAsync<T>(string destinationName, object request, IMessagePostProcessor requestPostProcessor, CancellationToken cancellationToken = null)
Parameters
Type | Name | Description |
---|---|---|
System.String | destinationName | the name of the target destination |
System.Object | request | the payload for the request message |
IMessagePostProcessor | requestPostProcessor | post process for the request message |
CancellationToken | cancellationToken | token used to signal cancelation |
Returns
Type | Description |
---|---|
Task<T> | a task to signal completion |
Type Parameters
Name | Description |
---|---|
T | the type of the reply |
SendAndReceive(String, IMessage)
Resolve the given destination name to a destination and send the given message, receive a reply and return it.
Declaration
IMessage SendAndReceive(string destinationName, IMessage requestMessage)
Parameters
Type | Name | Description |
---|---|---|
System.String | destinationName | the name of the target destination |
IMessage | requestMessage | the message to send |
Returns
Type | Description |
---|---|
IMessage | the received message or null if nothing received |
SendAndReceiveAsync(String, IMessage, CancellationToken)
Resolve the given destination name to a destination and send the given message, receive a reply and return it.
Declaration
Task<IMessage> SendAndReceiveAsync(string destinationName, IMessage requestMessage, CancellationToken cancellationToken = null)
Parameters
Type | Name | Description |
---|---|---|
System.String | destinationName | the name of the target destination |
IMessage | requestMessage | the message to send |
CancellationToken | cancellationToken | token used to signal cancelation |
Returns
Type | Description |
---|---|
Task<IMessage> | a task to signal completion |