Table of Contents

Interface IDestinationResolvingMessageRequestReplyOperations<D>

Namespace
Steeltoe.Messaging.Core
Assembly
Steeltoe.Messaging.Abstractions.dll

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 string

the name of the target destination

request object

the payload for the request message

requestPostProcessor IMessagePostProcessor

post process for the request message

cancellationToken CancellationToken

token 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 string

the name of the target destination

request object

the payload for the request message

headers IDictionary<string, object>

the headers to include in the message

requestPostProcessor IMessagePostProcessor

post process for the request message

cancellationToken CancellationToken

token 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 string

the name of the target destination

request object

the payload for the request message

headers IDictionary<string, object>

the headers to include in the message

cancellationToken CancellationToken

token 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 string

the name of the target destination

request object

the payload for the request message

cancellationToken CancellationToken

token 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 string

the name of the target destination

request object

the 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 string

the name of the target destination

request object

the payload for the request message

requestPostProcessor IMessagePostProcessor

post 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 string

the name of the target destination

request object

the 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 string

the name of the target destination

request object

the payload for the request message

headers IDictionary<string, object>

the headers to include in the message

requestPostProcessor IMessagePostProcessor

post 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 string

the name of the target destination

requestMessage IMessage

the 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 string

the name of the target destination

requestMessage IMessage

the message to send

cancellationToken CancellationToken

token used to signal cancelation

Returns

Task<IMessage>

a task to signal completion