Partilhar via


RequestResponseLink class

Descreve uma ligação amqp request(sender)-response(receiver) que é criada numa sessão amqp.

Construtores

RequestResponseLink(Session, Sender, Receiver)

Propriedades

connection

Fornece o objeto de ligação amqp subjacente.

receiver
sender
session

Métodos

close()

Fecha o remetente, a ligação do recetor e a sessão subjacente.

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

Cria uma ligação de pedido/resposta amqp.

isOpen()

Indica se as ligações da sessão e do remetente e do recetor estão todas abertas ou fechadas.

remove()

Remove o remetente, a ligação do recetor e a sessão subjacente.

sendRequest(Message, SendRequestOptions)

Envia a mensagem de pedido especificada e devolve a resposta recebida. Se a operação não for concluída no tempo limite fornecido em milissegundos default: 60000, OperationTimeoutError é emitida.

Detalhes do Construtor

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

Parâmetros

session

Session

A sessão amqp.

sender

Sender

A ligação do remetente amqp.

receiver

Receiver

A ligação do recetor amqp.

Detalhes de Propriedade

Fornece o objeto de ligação amqp subjacente.

Connection connection

Valor de Propriedade

Connection

Ligaçã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 remetente, a ligação do recetor e a sessão subjacente.

function close(): Promise<void>

Devoluções

Promise<void>

Promessa

Cria uma ligação de pedido/resposta amqp.

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

Parâmetros

connection

Connection

A ligação amqp.

senderOptions

SenderOptions

Opções que têm de ser fornecidas para criar a ligação do remetente.

receiverOptions

ReceiverOptions

Opções que têm de ser fornecidas para criar a ligação do recetor.

createOptions

{ abortSignal?: AbortSignalLike }

Parâmetros opcionais que podem ser utilizados para afetar o comportamento deste método. Por exemplo, abortSignal pode ser transmitido para permitir o cancelamento de uma invocação em curso create .

Devoluções

Promessa

Indica se as ligações da sessão e do remetente e do recetor estão todas abertas ou fechadas.

function isOpen(): boolean

Devoluções

boolean

booleano - true - open, . false - closed

Remove o remetente, a ligação do recetor e a sessão subjacente.

function remove()

Envia a mensagem de pedido especificada e devolve a resposta recebida. Se a operação não for concluída no tempo limite fornecido em milissegundos default: 60000, OperationTimeoutError é emitida.

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

Parâmetros

request

Message

A mensagem AMQP (pedido).

options
SendRequestOptions

Opções que podem ser fornecidas ao enviar um pedido.

Devoluções

Promise<Message>

Prometa a mensagem AMQP (resposta).