RequestResponseLink class
Descreve um link amqp request(sender)-response(receiver) que é criado em uma sessão amqp.
Construtores
Request |
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, Sender |
Cria um link de solicitação/resposta amqp. |
is |
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. |
send |
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 |
Detalhes do Construtor
RequestResponseLink(Session, Sender, Receiver)
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
connection
Fornece o objeto de conexão amqp subjacente.
Connection connection
Valor de Propriedade
Connection
Conexão.
receiver
receiver: Receiver
Valor de Propriedade
Receiver
sender
sender: Sender
Valor de Propriedade
Sender
session
session: Session
Valor de Propriedade
Session
Detalhes de Método
close()
Fecha o link remetente, recetor e a sessão subjacente.
function close(): Promise<void>
Devoluções
Promise<void>
Promessa
create(Connection, SenderOptions, ReceiverOptions, { abortSignal?: AbortSignalLike })
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
Promise<RequestResponseLink>
Promessa
isOpen()
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()
Remove o remetente, o link do destinatário e sua sessão subjacente.
function remove()
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.
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).