RequestResponseLink class
Descreve um link amqp request(sender)-response(receiver) 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 remetente, o link do receptor 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 de remetente e receptor estão todos abertos ou fechados. |
| remove() | Remove o remetente, o link do receptor e a 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 receptor amqp.
Detalhes da propriedade
connection
Fornece o objeto de conexão amqp subjacente.
Connection connectionValor da propriedade
Connection
Conexão.
receiver
receiver: ReceiverValor da propriedade
Receiver
sender
sender: SenderValor da propriedade
Sender
session
session: SessionValor da propriedade
Session
Detalhes do método
close()
Fecha o remetente, o link do receptor e a sessão subjacente.
function close(): Promise<void>Retornos
Promise<void>
Promessa<Void>
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 receptor.
- 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 invocação de create em andamento.
Retornos
Promise<RequestResponseLink>
Promessa<RequestResponseLink>
isOpen()
Indica se a sessão e os links de remetente e receptor estão todos abertos ou fechados.
function isOpen(): booleanRetornos
boolean
booliano - true - open, false - closed.
remove()
Remove o remetente, o link do receptor e a 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á gerada.
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 uma solicitação.
Retornos
Promise<Message>
Mensagem de Promessa<> A mensagem AMQP (resposta).