RequestResponseLink class

Pacchetto:

@azure/core-amqp

Descrive un collegamento amqp request(sender)-response(receiver) creato in una sessione amqp.

Costruttori

RequestResponseLink(Session, Sender, Receiver)

Proprietà

connection	Fornisce l'oggetto connessione amqp sottostante.
receiver
sender
session

Metodi

close()	Chiude il mittente, il collegamento destinatario e la sessione sottostante.
create(Connection, SenderOptions, ReceiverOptions, { abortSignal?: AbortSignalLike })	Crea un collegamento di richiesta/risposta amqp.
isOpen()	Indica se la sessione e i collegamenti mittente e destinatario sono tutti aperti o chiusi.
remove()	Rimuove il mittente, il collegamento destinatario ed è la sessione sottostante.
sendRequest(Message, SendRequestOptions)	Invia il messaggio di richiesta specificato e restituisce la risposta ricevuta. Se l'operazione non viene completata nel timeout specificato in millisecondi default: 60000, viene generata OperationTimeoutError.

Dettagli costruttore

RequestResponseLink(Session, Sender, Receiver)

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

Parametri

session

Session

Sessione amqp.

sender

Sender

Collegamento del mittente amqp.

receiver

Receiver

Collegamento del ricevitore amqp.

Dettagli proprietà

connection

Fornisce l'oggetto connessione amqp sottostante.

Connection connection

Valore della proprietà

Connection

Connessione.

receiver

receiver: Receiver

Valore della proprietà

Receiver

sender

sender: Sender

Valore della proprietà

Sender

session

session: Session

Valore della proprietà

Session

Dettagli metodo

close()

Chiude il mittente, il collegamento destinatario e la sessione sottostante.

function close(): Promise<void>

Restituisce

Promise<void>

Promessa<nulla>

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

Crea un collegamento di richiesta/risposta amqp.

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

Parametri

connection

Connection

Connessione amqp.

senderOptions

SenderOptions

Opzioni che devono essere fornite per creare il collegamento del mittente.

receiverOptions

ReceiverOptions

Opzioni che devono essere fornite per creare il collegamento del ricevitore.

createOptions

{ abortSignal?: AbortSignalLike }

Parametri facoltativi che possono essere usati per influire sul comportamento di questo metodo. Ad esempio, è possibile passare abortSignal per consentire l'annullamento di una chiamata create in corso.

Restituisce

Promise<RequestResponseLink>

Prometti<RequestResponseLink>

isOpen()

Indica se la sessione e i collegamenti mittente e destinatario sono tutti aperti o chiusi.

function isOpen(): boolean

Restituisce

boolean

boolean: true - open, false - closed.

remove()

Rimuove il mittente, il collegamento destinatario ed è la sessione sottostante.

function remove()

sendRequest(Message, SendRequestOptions)

Invia il messaggio di richiesta specificato e restituisce la risposta ricevuta. Se l'operazione non viene completata nel timeout specificato in millisecondi default: 60000, viene generata OperationTimeoutError.

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

Parametri

request

Message

Messaggio AMQP (richiesta).

options

SendRequestOptions

Opzioni che possono essere fornite durante l'invio di una richiesta.

Restituisce

Promise<Message>

Messaggio> di promessa<Il messaggio AMQP (risposta).