RequestResponseLink class
Descreve uma ligação amqp request(sender)-response(receiver) que é criada numa sessão amqp.
Construtores
Request |
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, Sender |
Cria uma ligação de pedido/resposta amqp. |
is |
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. |
send |
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 |
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
A ligação do remetente amqp.
- receiver
-
Receiver
A ligação do recetor amqp.
Detalhes de Propriedade
connection
Fornece o objeto de ligação amqp subjacente.
Connection connection
Valor de Propriedade
Connection
Ligaçã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 remetente, a ligação do recetor e a sessão subjacente.
function close(): Promise<void>
Devoluções
Promise<void>
Promessa
create(Connection, SenderOptions, ReceiverOptions, { abortSignal?: AbortSignalLike })
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
Promise<RequestResponseLink>
Promessa
isOpen()
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()
Remove o remetente, a ligação do recetor e a sessão subjacente.
function remove()
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.
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).