RequestResponseLink class

Pacote:

@azure/core-amqp

Descreve um link amqp request(sender)-response(receiver) 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 remetente, o link do receptor e a sessão subjacente.
create(Connection, SenderOptions, ReceiverOptions, { abortSignal?: AbortSignalLike })	Cria um link de solicitação/resposta amqp.
isOpen()	Indica se a sessão e os links do remetente e do receptor estão todos abertos ou fechados.
remove()	Remove o remetente, o link do receptor e a 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 milissegundos default: 60000, será OperationTimeoutError gerada.

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 connection

Valor da propriedade

Connection

Connection.

receiver

receiver: Receiver

Valor da propriedade

Receiver

sender

sender: Sender

Valor da propriedade

Sender

session

session: Session

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

Prometo

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 em andamento create .

Retornos

Promise<RequestResponseLink>

Prometo

isOpen()

Indica se a sessão e os links do remetente e do receptor estão todos abertos ou fechados.

function isOpen(): boolean

Retornos

boolean

boolean - 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, será OperationTimeoutError 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>

Prometa a mensagem AMQP (resposta).