Partilhar via


RequestResponseLink class

Descreve um link amqp request(sender)-response(receiver) que é criado em uma sessão amqp.

Construtores

RequestResponseLink(Session, Sender, Receiver)

Propriedades

connection

Fornece o objeto de conexão amqp subjacente.

receiver
sender
session

Métodos

close()

Fecha o link remetente, recetor e a sessão subjacente.

create(Connection, SenderOptions, ReceiverOptions, { abortSignal?: AbortSignalLike })

Cria um link de solicitação/resposta amqp.

isOpen()

Indica se a sessão e os links remetente e recetor estão todos abertos ou fechados.

remove()

Remove o remetente, o link do destinatário e sua sessão subjacente.

sendRequest(Message, SendRequestOptions)

Envia a mensagem de solicitação fornecida e retorna a resposta recebida. Se a operação não for concluída no tempo limite fornecido em milissegundos default: 60000, OperationTimeoutError será lançada.

Detalhes do Construtor

new RequestResponseLink(session: Session, sender: Sender, receiver: Receiver)

Parâmetros

session

Session

A sessão amqp.

sender

Sender

O link do remetente amqp.

receiver

Receiver

O link do recetor amqp.

Detalhes de Propriedade

Fornece o objeto de conexão amqp subjacente.

Connection connection

Valor de Propriedade

Connection

Conexão.

receiver: Receiver

Valor de Propriedade

Receiver

sender: Sender

Valor de Propriedade

Sender

session: Session

Valor de Propriedade

Session

Detalhes de Método

Fecha o link remetente, recetor e a sessão subjacente.

function close(): Promise<void>

Devoluções

Promise<void>

Promessa

Cria um link de solicitação/resposta amqp.

static function create(connection: Connection, senderOptions: SenderOptions, receiverOptions: ReceiverOptions, createOptions?: { abortSignal?: AbortSignalLike }): Promise<RequestResponseLink>

Parâmetros

connection

Connection

A conexão amqp.

senderOptions

SenderOptions

Opções que devem ser fornecidas para criar o link do remetente.

receiverOptions

ReceiverOptions

Opções que devem ser fornecidas para criar o link do recetor.

createOptions

{ abortSignal?: AbortSignalLike }

Parâmetros opcionais que podem ser usados para afetar o comportamento desse método. Por exemplo, abortSignal pode ser passado para permitir o cancelamento de uma create em andamento invocação.

Devoluções

Promessa

Indica se a sessão e os links remetente e recetor estão todos abertos ou fechados.

function isOpen(): boolean

Devoluções

boolean

Booleano - true - open, false - closed.

Remove o remetente, o link do destinatário e sua sessão subjacente.

function remove()

Envia a mensagem de solicitação fornecida e retorna a resposta recebida. Se a operação não for concluída no tempo limite fornecido em milissegundos default: 60000, OperationTimeoutError será lançada.

function sendRequest(request: Message, options?: SendRequestOptions): Promise<Message>

Parâmetros

request

Message

A mensagem AMQP (solicitação).

options
SendRequestOptions

Opções que podem ser fornecidas durante o envio de um pedido.

Devoluções

Promise<Message>

Promessa A mensagem AMQP (resposta).