RequestResponseLink class

Paket:

@azure/amqp-common

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)	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 im bereitgestellten Timeout in Sekunden default: 10nicht abgeschlossen ist, wird die Anforderung linear für die angegebene Anzahl von default: 3 mit der bereitgestellten Verzögerung in Sekunden default: 15 zwischen jedem Versuch wiederholt.

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)

Erstellt einen amqp-Anforderungs-/Antwortlink.

static function create(connection: Connection, senderOptions: SenderOptions, receiverOptions: ReceiverOptions): 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.

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 im bereitgestellten Timeout in Sekunden default: 10nicht abgeschlossen ist, wird die Anforderung linear für die angegebene Anzahl von default: 3 mit der bereitgestellten Verzögerung in Sekunden default: 15 zwischen jedem Versuch wiederholt.

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

Parameter

request

AmqpMessage

Die AMQP-Nachricht (Anforderung).

options

SendRequestOptions

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

Gibt zurück

Promise<AmqpMessage>

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