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

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 "запрос-ответ".
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>

Promise

Создает ссылку amqp "запрос-ответ".

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>

Promise

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

function isOpen(): boolean

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

boolean

boolean — true - open, false - closed.

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

function remove()

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

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

Параметры

request

Message

Сообщение AMQP (запрос).

options
SendRequestOptions

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

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

Promise<Message>

Обещание Сообщение AMQP (ответ).