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)

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 segundos default: 10, a solicitação será repetida linearmente pelo número de vezes fornecido default: 3 com o atraso fornecido em segundos default: 15 entre cada tentativa.

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<anulada>

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

static function create(connection: Connection, senderOptions: SenderOptions, receiverOptions: ReceiverOptions): 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.

Devoluções

Promessa<RequestResponseLink>

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 segundos default: 10, a solicitação será repetida linearmente pelo número de vezes fornecido default: 3 com o atraso fornecido em segundos default: 15 entre cada tentativa.

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

Parâmetros

request
AmqpMessage

A mensagem AMQP (solicitação).

options
SendRequestOptions

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

Devoluções

Promise<AmqpMessage>

Mensagem< de promessa>A mensagem AMQP (resposta).