RequestResponseLink class

Paket:

@azure/core-amqp

Beschreibt einen amqp request(sender)-response(receiver)-link, der über eine amqp-Sitzung erstellt wird.

Konstruktoren

RequestResponseLink(Session, Sender, Receiver)

Eigenschaften

connection	Stellt das zugrunde liegende amqp-Verbindungsobjekt bereit.
receiver
sender
session

Methoden

close()	Schließt den Absender, den Empfängerlink und die zugrunde liegende Sitzung.
create(Connection, SenderOptions, ReceiverOptions, { abortSignal?: AbortSignalLike })	Erstellt einen amqp-Anforderungs-/Antwortlink.
isOpen()	Gibt an, ob die Sitzung und die Absender- und Empfängerlinks alle geöffnet oder geschlossen sind.
remove()	Entfernt den Absender, den Empfängerlink und die zugrunde liegende Sitzung.
sendRequest(Message, SendRequestOptions)	Sendet die angegebene Anforderungsnachricht und gibt die empfangene Antwort zurück. Wenn der Vorgang nicht im bereitgestellten Timeout in Millisekunden default: 60000abgeschlossen ist, wird OperationTimeoutError ausgelöst.

Details zum Konstruktor

RequestResponseLink(Session, Sender, Receiver)

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

Parameter

session

Session

Die amqp-Sitzung.

sender

Sender

Der Amqp-Absenderlink.

receiver

Receiver

Die Amqp-Empfängerverbindung.

Details zur Eigenschaft

connection

Stellt das zugrunde liegende amqp-Verbindungsobjekt bereit.

Connection connection

Eigenschaftswert

Connection

Verbindung.

receiver

receiver: Receiver

Eigenschaftswert

Receiver

sender

sender: Sender

Eigenschaftswert

Sender

session

session: Session

Eigenschaftswert

Session

Details zur Methode

close()

Schließt den Absender, den Empfängerlink und die zugrunde liegende Sitzung.

function close(): Promise<void>

Gibt zurück

Promise<void>

Versprechen<ungültig>

create(Connection, SenderOptions, ReceiverOptions, { abortSignal?: AbortSignalLike })

Erstellt einen amqp-Anforderungs-/Antwortlink.

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

Parameter

connection

Connection

Die amqp-Verbindung.

senderOptions

SenderOptions

Optionen, die zum Erstellen des Absenderlinks bereitgestellt werden müssen.

receiverOptions

ReceiverOptions

Optionen, die zum Erstellen der Empfängerverbindung bereitgestellt werden müssen.

createOptions

{ abortSignal?: AbortSignalLike }

Optionale Parameter, die verwendet werden können, um das Verhalten dieser Methode zu beeinflussen. Beispielsweise können abortSignal übergeben werden, um das Abbrechen eines laufenden create Aufrufs zuzulassen.

Gibt zurück

Promise<RequestResponseLink>

Versprechen<Sie RequestResponseLink>

isOpen()

Gibt an, ob die Sitzung und die Absender- und Empfängerlinks alle geöffnet oder geschlossen sind.

function isOpen(): boolean

Gibt zurück

boolean

boolescher Wert - true - open, false - closed.

remove()

Entfernt den Absender, den Empfängerlink und die zugrunde liegende Sitzung.

function remove()

sendRequest(Message, SendRequestOptions)

Sendet die angegebene Anforderungsnachricht und gibt die empfangene Antwort zurück. Wenn der Vorgang nicht im bereitgestellten Timeout in Millisekunden default: 60000abgeschlossen ist, wird OperationTimeoutError ausgelöst.

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

Parameter

request

Message

Die AMQP-Nachricht (Anforderung).

options

SendRequestOptions

Optionen, die beim Senden einer Anforderung bereitgestellt werden können.

Gibt zurück

Promise<Message>

Promise<Message> Die AMQP-Nachricht (Antwortnachricht).