Поделиться через

RequestResponseLink class

Пакет:
@azure/core-amqp

Описывает ссылку amqp request(sender)-response(receiver), созданную через сеанс amqp.

Конструкторы

RequestResponseLink(Session, Sender, Receiver)

Свойства

connection

Предоставляет базовый объект подключения amqp.
receiver
sender
session

Методы

close()

Закрывает отправитель, ссылку получателя и базовый сеанс.
create(Connection, SenderOptions, ReceiverOptions, { abortSignal?: AbortSignalLike })

Создает ссылку amqp request/response.
isOpen()

Указывает, открыты ли или закрыты ссылки на сеанс и отправитель и получатель.
remove()

Удаляет отправитель, ссылку получателя и это базовый сеанс.
sendRequest(Message, SendRequestOptions)

Отправляет заданное сообщение запроса и возвращает полученный ответ. Если операция не завершена в предоставленном времени ожидания в миллисекундах default: 60000, возникает OperationTimeoutError.

Сведения о конструкторе

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

Параметры

session

Session

Сеанс amqp.

sender

Sender

Ссылка отправителя amqp.

receiver

Receiver

Ссылка приемника amqp.

Сведения о свойстве

Предоставляет базовый объект подключения amqp.

Connection connection

Значение свойства

Connection

Связь.

receiver: Receiver

Значение свойства

Receiver

sender: Sender

Значение свойства

Sender

session: Session

Значение свойства

Session

Сведения о методе

Закрывает отправитель, ссылку получателя и базовый сеанс.

function close(): Promise<void>

Возвращаемое значение

Promise<void>

Обещание<не выполнено>

Создает ссылку amqp request/response.

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

Параметры

connection

Connection

Подключение amqp.

senderOptions

SenderOptions

Параметры, которые должны быть предоставлены для создания ссылки отправителя.

receiverOptions

ReceiverOptions

Параметры, которые должны быть предоставлены для создания ссылки получателя.

createOptions

{ abortSignal?: AbortSignalLike }

Необязательные параметры, которые можно использовать для влияния на поведение этого метода. Например, abortSignal можно передать, чтобы разрешить отмену выполнения create вызова.

Возвращаемое значение

Promise<RequestResponseLink>

Обещание<RequestResponseLink>

Указывает, открыты ли или закрыты ссылки на сеанс и отправитель и получатель.

function isOpen(): boolean

Возвращаемое значение

boolean

логический — true - open, false - closed.

Удаляет отправитель, ссылку получателя и это базовый сеанс.

function remove()

Отправляет заданное сообщение запроса и возвращает полученный ответ. Если операция не завершена в предоставленном времени ожидания в миллисекундах default: 60000, возникает OperationTimeoutError.

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

Параметры

request

Message

Сообщение AMQP (request).

options
SendRequestOptions

Параметры, которые можно предоставить при отправке запроса.

Возвращаемое значение

Promise<Message>

Promise<Message (Promise Message> ) Сообщение AMQP (ответ).