Interface IRequester

Namespace

RabbitMQ.AMQP.Client

Assembly

RabbitMQ.AMQP.Client.dll

IRpcClient is the interface for an RPC client. See also IResponder and IRequesterBuilder

public interface IRequester : ILifeCycle, IDisposable

Inherited Members

ILifeCycle.CloseAsync()

ILifeCycle.State

ILifeCycle.ChangeState

IDisposable.Dispose()

Methods

GetReplyToQueue()

The ReplyTo queue address can be created by:

• the client providing a specific queue name
• the client creating a temporary queue
• The server uses this address to send the reply message. with direct-reply-to

string GetReplyToQueue()

Returns

string

PublishAsync(IMessage, CancellationToken)

PublishAsync sends a request message to the server and blocks the thread until the response is received. The PublishAsync is thread-safe and can be called from multiple threads. The Function returns the response message. If the server does not respond within the timeout, the function throws a TimeoutException.

Task<IMessage> PublishAsync(IMessage message, CancellationToken cancellationToken = default)

Parameters

message IMessage

The request message

cancellationToken CancellationToken

Cancellation token

Returns

Task<IMessage>