Interface IMessageRequestReplyOperations<D>
Operations for sending messages to and receiving the reply from a destination.
Namespace: Steeltoe.Messaging.Core
Assembly: Steeltoe.Messaging.Abstractions.dll
Syntax
public interface IMessageRequestReplyOperations<D>Type Parameters
| Name | Description |
|---|---|
| D | the type of the destination |
Methods
| Edit this page View SourceConvertSendAndReceive<T>(D, Object)
Convert the given request object to serialized form, possibly using a message converter, send it as a message to a specified destination, receive the reply and convert its body to the specified target type.
Declaration
T ConvertSendAndReceive<T>(D destination, object request)Parameters
| Type | Name | Description |
|---|---|---|
| D | destination | the target destination |
| System.Object | request | payload for the request message to send |
Returns
| Type | Description |
|---|---|
| T | the receieved message; or null |
Type Parameters
| Name | Description |
|---|---|
| T | the target type of the payload |
ConvertSendAndReceive<T>(D, Object, IDictionary<String, Object>)
Convert the given request object to serialized form, possibly using a message converter, send it as a message to a specified destination with the given headers, receive the reply and convert its body to the specified target type.
Declaration
T ConvertSendAndReceive<T>(D destination, object request, IDictionary<string, object> headers)Parameters
| Type | Name | Description |
|---|---|---|
| D | destination | the target destination |
| System.Object | request | payload for the request message to send |
| IDictionary<System.String, System.Object> | headers | the headers to send |
Returns
| Type | Description |
|---|---|
| T | the receieved message; or null |
Type Parameters
| Name | Description |
|---|---|
| T | the target type of the payload |
ConvertSendAndReceive<T>(D, Object, IDictionary<String, Object>, IMessagePostProcessor)
Convert the given request object to serialized form, possibly using a message converter, send it as a message to the specified destination after applying the post processor, with the specified headers, receive the reply and convert its body to the specified target type.
Declaration
T ConvertSendAndReceive<T>(D destination, object request, IDictionary<string, object> headers, IMessagePostProcessor requestPostProcessor)Parameters
| Type | Name | Description |
|---|---|---|
| D | destination | the target destination |
| System.Object | request | payload for the request message to send |
| IDictionary<System.String, System.Object> | headers | the headers to send |
| IMessagePostProcessor | requestPostProcessor | the post processor to apply |
Returns
| Type | Description |
|---|---|
| T | the receieved message; or null |
Type Parameters
| Name | Description |
|---|---|
| T | the target type of the reply |
ConvertSendAndReceive<T>(D, Object, IMessagePostProcessor)
Convert the given request object to serialized form, possibly using a message converter, send it as a message to the specified destination after applying the post processor, receive the reply and convert its body to the specified target type.
Declaration
T ConvertSendAndReceive<T>(D destination, object request, IMessagePostProcessor requestPostProcessor)Parameters
| Type | Name | Description |
|---|---|---|
| D | destination | the target destination |
| System.Object | request | payload for the request message to send |
| IMessagePostProcessor | requestPostProcessor | the post processor to apply |
Returns
| Type | Description |
|---|---|
| T | the receieved message; or null |
Type Parameters
| Name | Description |
|---|---|
| T | the target type of the reply |
ConvertSendAndReceive<T>(Object)
Convert the given request object to serialized form, possibly using a message converter, send it as a message to a default destination, receive the reply and convert its body to the specified target type.
Declaration
T ConvertSendAndReceive<T>(object request)Parameters
| Type | Name | Description |
|---|---|---|
| System.Object | request | payload for the request message to send |
Returns
| Type | Description |
|---|---|
| T | the receieved message; or null |
Type Parameters
| Name | Description |
|---|---|
| T | the target type of the payload |
ConvertSendAndReceive<T>(Object, IMessagePostProcessor)
Convert the given request object to serialized form, possibly using a message converter, send it as a message to a default destination after applying the post processor, receive the reply and convert its body to the specified target type.
Declaration
T ConvertSendAndReceive<T>(object request, IMessagePostProcessor requestPostProcessor)Parameters
| Type | Name | Description |
|---|---|---|
| System.Object | request | payload for the request message to send |
| IMessagePostProcessor | requestPostProcessor | the post processor to apply |
Returns
| Type | Description |
|---|---|
| T | the receieved message; or null |
Type Parameters
| Name | Description |
|---|---|
| T | the target type of the reply |
ConvertSendAndReceiveAsync<T>(D, Object, CancellationToken)
Convert the given request object to serialized form, possibly using a message converter, send it as a message to a specified destination, receive the reply and convert its body to the specified target type.
Declaration
Task<T> ConvertSendAndReceiveAsync<T>(D destination, object request, CancellationToken cancellationToken = null)Parameters
| Type | Name | Description |
|---|---|---|
| D | destination | the target destination |
| System.Object | request | payload for the request message to send |
| CancellationToken | cancellationToken | token used to signal cancelation |
Returns
| Type | Description |
|---|---|
| Task<T> | a task to signal completion |
Type Parameters
| Name | Description |
|---|---|
| T | the target type of the payload |
ConvertSendAndReceiveAsync<T>(D, Object, IDictionary<String, Object>, CancellationToken)
Convert the given request object to serialized form, possibly using a message converter, send it as a message to a specified destination with the given headers, receive the reply and convert its body to the specified target type.
Declaration
Task<T> ConvertSendAndReceiveAsync<T>(D destination, object request, IDictionary<string, object> headers, CancellationToken cancellationToken = null)Parameters
| Type | Name | Description |
|---|---|---|
| D | destination | the target destination |
| System.Object | request | payload for the request message to send |
| IDictionary<System.String, System.Object> | headers | the headers to send |
| CancellationToken | cancellationToken | token used to signal cancelation |
Returns
| Type | Description |
|---|---|
| Task<T> | a task to signal completion |
Type Parameters
| Name | Description |
|---|---|
| T | the target type of the payload |
ConvertSendAndReceiveAsync<T>(D, Object, IDictionary<String, Object>, IMessagePostProcessor, CancellationToken)
Convert the given request object to serialized form, possibly using a message converter, send it as a message to the specified destination after applying the post processor, with the specified headers, receive the reply and convert its body to the specified target type.
Declaration
Task<T> ConvertSendAndReceiveAsync<T>(D destination, object request, IDictionary<string, object> headers, IMessagePostProcessor requestPostProcessor, CancellationToken cancellationToken = null)Parameters
| Type | Name | Description |
|---|---|---|
| D | destination | the target destination |
| System.Object | request | payload for the request message to send |
| IDictionary<System.String, System.Object> | headers | the headers to send |
| IMessagePostProcessor | requestPostProcessor | the post processor to apply |
| CancellationToken | cancellationToken | token used to signal cancelation |
Returns
| Type | Description |
|---|---|
| Task<T> | a task to signal completion |
Type Parameters
| Name | Description |
|---|---|
| T | the target type of the reply |
ConvertSendAndReceiveAsync<T>(D, Object, IMessagePostProcessor, CancellationToken)
Convert the given request object to serialized form, possibly using a message converter, send it as a message to the specified destination after applying the post processor, receive the reply and convert its body to the specified target type.
Declaration
Task<T> ConvertSendAndReceiveAsync<T>(D destination, object request, IMessagePostProcessor requestPostProcessor, CancellationToken cancellationToken = null)Parameters
| Type | Name | Description |
|---|---|---|
| D | destination | the target destination |
| System.Object | request | payload for the request message to send |
| IMessagePostProcessor | requestPostProcessor | the post processor to apply |
| CancellationToken | cancellationToken | token used to signal cancelation |
Returns
| Type | Description |
|---|---|
| Task<T> | a task to signal completion |
Type Parameters
| Name | Description |
|---|---|
| T | the target type of the reply |
ConvertSendAndReceiveAsync<T>(Object, CancellationToken)
Convert the given request object to serialized form, possibly using a message converter, send it as a message to a default destination, receive the reply and convert its body to the specified target type.
Declaration
Task<T> ConvertSendAndReceiveAsync<T>(object request, CancellationToken cancellationToken = null)Parameters
| Type | Name | Description |
|---|---|---|
| System.Object | request | payload for the request message to send |
| CancellationToken | cancellationToken | token used to signal cancelation |
Returns
| Type | Description |
|---|---|
| Task<T> | a task to signal completion |
Type Parameters
| Name | Description |
|---|---|
| T | the target type of the payload |
ConvertSendAndReceiveAsync<T>(Object, IMessagePostProcessor, CancellationToken)
Convert the given request object to serialized form, possibly using a message converter, send it as a message to a default destination after applying the post processor, receive the reply and convert its body to the specified target type.
Declaration
Task<T> ConvertSendAndReceiveAsync<T>(object request, IMessagePostProcessor requestPostProcessor, CancellationToken cancellationToken = null)Parameters
| Type | Name | Description |
|---|---|---|
| System.Object | request | payload for the request message to send |
| IMessagePostProcessor | requestPostProcessor | the post processor to apply |
| CancellationToken | cancellationToken | token used to signal cancelation |
Returns
| Type | Description |
|---|---|
| Task<T> | a task to signal completion |
Type Parameters
| Name | Description |
|---|---|
| T | the target type of the reply |
SendAndReceive(D, IMessage)
Send a request message and receive the reply from the given destination.
Declaration
IMessage SendAndReceive(D destination, IMessage requestMessage)Parameters
| Type | Name | Description |
|---|---|---|
| D | destination | the target destination |
| IMessage | requestMessage | the message to send |
Returns
| Type | Description |
|---|---|
| IMessage | the receieved message; or null |
SendAndReceive(IMessage)
Send a request message and receive the reply from a default destination.
Declaration
IMessage SendAndReceive(IMessage requestMessage)Parameters
| Type | Name | Description |
|---|---|---|
| IMessage | requestMessage | the message to send |
Returns
| Type | Description |
|---|---|
| IMessage | the receieved message; or null |
SendAndReceiveAsync(D, IMessage, CancellationToken)
Send a request message and receive the reply from the given destination.
Declaration
Task<IMessage> SendAndReceiveAsync(D destination, IMessage requestMessage, CancellationToken cancellationToken = null)Parameters
| Type | Name | Description |
|---|---|---|
| D | destination | 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 |
SendAndReceiveAsync(IMessage, CancellationToken)
Send a request message and receive the reply from a default destination.
Declaration
Task<IMessage> SendAndReceiveAsync(IMessage requestMessage, CancellationToken cancellationToken = null)Parameters
| Type | Name | Description |
|---|---|---|
| IMessage | requestMessage | the message to send |
| CancellationToken | cancellationToken | token used to signal cancelation |
Returns
| Type | Description |
|---|---|
| Task<IMessage> | a task to signal completion |