Interface IDestinationResolvingMessageRequestReplyOperations<D>
Provide operations for sending and receiving messages to and from a destination specified as a string
public interface IDestinationResolvingMessageRequestReplyOperations<D> : IMessageRequestReplyOperations<D>
Type Parameters
D
the type of the destination
- Inherited Members
Methods
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.
Task<T> ConvertSendAndReceiveAsync<T>(string destinationName, object request, IMessagePostProcessor requestPostProcessor, CancellationToken cancellationToken = default)
Parameters
destinationName
stringthe name of the target destination
request
objectthe payload for the request message
requestPostProcessor
IMessagePostProcessorpost process for the request message
cancellationToken
CancellationTokentoken used to signal cancelation
Returns
- Task<T>
a task to signal completion
Type Parameters
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.
Task<T> ConvertSendAndReceiveAsync<T>(string destinationName, object request, IDictionary<string, object> headers, IMessagePostProcessor requestPostProcessor, CancellationToken cancellationToken = default)
Parameters
destinationName
stringthe name of the target destination
request
objectthe payload for the request message
headers
IDictionary<string, object>the headers to include in the message
requestPostProcessor
IMessagePostProcessorpost process for the request message
cancellationToken
CancellationTokentoken used to signal cancelation
Returns
- Task<T>
a task to signal completion
Type Parameters
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.
Task<T> ConvertSendAndReceiveAsync<T>(string destinationName, object request, IDictionary<string, object> headers, CancellationToken cancellationToken = default)
Parameters
destinationName
stringthe name of the target destination
request
objectthe payload for the request message
headers
IDictionary<string, object>the headers to include in the message
cancellationToken
CancellationTokentoken used to signal cancelation
Returns
- Task<T>
a task to signal completion
Type Parameters
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.
Task<T> ConvertSendAndReceiveAsync<T>(string destinationName, object request, CancellationToken cancellationToken = default)
Parameters
destinationName
stringthe name of the target destination
request
objectthe payload for the request message
cancellationToken
CancellationTokentoken used to signal cancelation
Returns
- Task<T>
a task to signal completion
Type Parameters
T
the type of the reply
ConvertSendAndReceive<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.
T ConvertSendAndReceive<T>(string destinationName, object request)
Parameters
destinationName
stringthe name of the target destination
request
objectthe payload for the request message
Returns
- T
the converted payload of the reply message, possibly null
Type Parameters
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.
T ConvertSendAndReceive<T>(string destinationName, object request, IMessagePostProcessor requestPostProcessor)
Parameters
destinationName
stringthe name of the target destination
request
objectthe payload for the request message
requestPostProcessor
IMessagePostProcessorpost process for the request message
Returns
- T
the converted payload of the reply message, possibly null
Type Parameters
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.
T ConvertSendAndReceive<T>(string destinationName, object request, IDictionary<string, object> headers)
Parameters
destinationName
stringthe name of the target destination
request
objectthe payload for the request message
headers
IDictionary<string, object>the headers to include in the message
Returns
- T
the converted payload of the reply message, possibly null
Type Parameters
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.
T ConvertSendAndReceive<T>(string destinationName, object request, IDictionary<string, object> headers, IMessagePostProcessor requestPostProcessor)
Parameters
destinationName
stringthe name of the target destination
request
objectthe payload for the request message
headers
IDictionary<string, object>the headers to include in the message
requestPostProcessor
IMessagePostProcessorpost process for the request message
Returns
- T
the converted payload of the reply message, possibly null
Type Parameters
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.
IMessage SendAndReceive(string destinationName, IMessage requestMessage)
Parameters
destinationName
stringthe name of the target destination
requestMessage
IMessagethe message to send
Returns
- 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.
Task<IMessage> SendAndReceiveAsync(string destinationName, IMessage requestMessage, CancellationToken cancellationToken = default)
Parameters
destinationName
stringthe name of the target destination
requestMessage
IMessagethe message to send
cancellationToken
CancellationTokentoken used to signal cancelation