Udostępnij za pośrednictwem

RequestResponseLink class

  • Odwołanie
Pakiet:
@azure/core-amqp

Opisuje link amqp request(sender)-response(receiver), który jest tworzony za pośrednictwem sesji amqp.

Konstruktory

RequestResponseLink(Session, Sender, Receiver)

Właściwości

connection

Udostępnia podstawowy obiekt połączenia amqp.
receiver
sender
session

Metody

close()

Zamyka nadawcę, link odbiorcy i sesję bazową.
create(Connection, SenderOptions, ReceiverOptions, { abortSignal?: AbortSignalLike })

Tworzy link żądania/odpowiedzi amqp.
isOpen()

Wskazuje, czy sesja oraz łącza nadawcy i odbiorcy są otwarte lub zamknięte.
remove()

Usuwa nadawcę, link odbiorcy i jest to sesja bazowa.
sendRequest(Message, SendRequestOptions)

Wysyła dany komunikat żądania i zwraca odebraną odpowiedź. Jeśli operacja nie zostanie ukończona w podanym przekroczeniu limitu czasu w milisekundach default: 60000, OperationTimeoutError zostanie zgłoszony.

Szczegóły konstruktora

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

Parametry

session

Session

Sesja amqp.

sender

Sender

Link nadawcy amqp.

receiver

Receiver

Link odbiorcy amqp.

Szczegóły właściwości

Udostępnia podstawowy obiekt połączenia amqp.

Connection connection

Wartość właściwości

Connection

Połączenia.

receiver: Receiver

Wartość właściwości

Receiver

sender: Sender

Wartość właściwości

Sender

session: Session

Wartość właściwości

Session

Szczegóły metody

Zamyka nadawcę, link odbiorcy i sesję bazową.

function close(): Promise<void>

Zwraca

Promise<void>

Obietnica

Tworzy link żądania/odpowiedzi amqp.

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

Parametry

connection

Connection

Połączenie amqp.

senderOptions

SenderOptions

Opcje, które należy podać, aby utworzyć link nadawcy.

receiverOptions

ReceiverOptions

Opcje, które należy podać, aby utworzyć link odbiorcy.

createOptions

{ abortSignal?: AbortSignalLike }

Opcjonalne parametry, których można użyć do wpływu na zachowanie tej metody. Można na przykład abortSignal przekazać polecenie w celu umożliwienia anulowania wywołania w toku create .

Zwraca

Promise<RequestResponseLink>

Obietnica

Wskazuje, czy sesja oraz łącza nadawcy i odbiorcy są otwarte lub zamknięte.

function isOpen(): boolean

Zwraca

boolean

wartość logiczna — true - open, . false - closed

Usuwa nadawcę, link odbiorcy i jest to sesja bazowa.

function remove()

Wysyła dany komunikat żądania i zwraca odebraną odpowiedź. Jeśli operacja nie zostanie ukończona w podanym przekroczeniu limitu czasu w milisekundach default: 60000, OperationTimeoutError zostanie zgłoszony.

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

Parametry

request

Message

Komunikat AMQP (żądanie).

options
SendRequestOptions

Opcje, które można podać podczas wysyłania żądania.

Zwraca

Promise<Message>

Promise Komunikat AMQP (odpowiedź).