Partager via

RequestResponseLink class

  • Référence
Paquet:
@azure/core-amqp

Décrit un lien amqp request(sender)-response(receiver) créé sur une session amqp.

Constructeurs

RequestResponseLink(Session, Sender, Receiver)

Propriétés

connection

Fournit l’objet de connexion amqp sous-jacent.
receiver
sender
session

Méthodes

close()

Ferme l’expéditeur, le lien récepteur et la session sous-jacente.
create(Connection, SenderOptions, ReceiverOptions, { abortSignal?: AbortSignalLike })

Crée un lien de demande/réponse amqp.
isOpen()

Indique si la session et les liens expéditeur et récepteur sont tous ouverts ou fermés.
remove()

Supprime l’expéditeur, le lien récepteur et sa session sous-jacente.
sendRequest(Message, SendRequestOptions)

Envoie le message de demande donné et retourne la réponse reçue. Si l’opération n’est pas terminée dans le délai d’expiration fourni en millisecondes default: 60000, OperationTimeoutError est levée.

Détails du constructeur

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

Paramètres

session

Session

Session amqp.

sender

Sender

Lien de l’expéditeur amqp.

receiver

Receiver

Lien du récepteur amqp.

Détails de la propriété

Fournit l’objet de connexion amqp sous-jacent.

Connection connection

Valeur de propriété

Connection

Connexion.

receiver: Receiver

Valeur de propriété

Receiver

sender: Sender

Valeur de propriété

Sender

session: Session

Valeur de propriété

Session

Détails de la méthode

Ferme l’expéditeur, le lien récepteur et la session sous-jacente.

function close(): Promise<void>

Retours

Promise<void>

Promesse

Crée un lien de demande/réponse amqp.

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

Paramètres

connection

Connection

Connexion amqp.

senderOptions

SenderOptions

Options qui doivent être fournies pour créer le lien expéditeur.

receiverOptions

ReceiverOptions

Options qui doivent être fournies pour créer le lien récepteur.

createOptions

{ abortSignal?: AbortSignalLike }

Paramètres facultatifs qui peuvent être utilisés pour affecter le comportement de cette méthode. Par exemple, abortSignal pouvez autoriser l’annulation d’un appel en cours create.

Retours

Promise<RequestResponseLink>

Promesse

Indique si la session et les liens expéditeur et récepteur sont tous ouverts ou fermés.

function isOpen(): boolean

Retours

boolean

booléen - true - open, false - closed.

Supprime l’expéditeur, le lien récepteur et sa session sous-jacente.

function remove()

Envoie le message de demande donné et retourne la réponse reçue. Si l’opération n’est pas terminée dans le délai d’expiration fourni en millisecondes default: 60000, OperationTimeoutError est levée.

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

Paramètres

request

Message

Message AMQP (demande).

options
SendRequestOptions

Options qui peuvent être fournies lors de l’envoi d’une demande.

Retours

Promise<Message>

Promesse du message AMQP (réponse).