RequestResponseLink class

Pakket:

@azure/core-amqp

Beschrijft een amqp-aanvraag(afzender)-antwoordkoppeling (ontvanger) die is gemaakt via een amqp-sessie.

Constructors

RequestResponseLink(Session, Sender, Receiver)

Eigenschappen

connection	Biedt het onderliggende amqp-verbindingsobject.
receiver
sender
session

Methoden

close()	Hiermee sluit u de afzender, ontvangerkoppeling en de onderliggende sessie.
create(Connection, SenderOptions, ReceiverOptions, { abortSignal?: AbortSignalLike })	Hiermee maakt u een amqp-aanvraag/antwoordkoppeling.
isOpen()	Geeft aan of de sessie en de koppelingen van de afzender en ontvanger allemaal open of gesloten zijn.
remove()	Hiermee verwijdert u de afzender, ontvangerkoppeling en de onderliggende sessie.
sendRequest(Message, SendRequestOptions)	Hiermee wordt het opgegeven aanvraagbericht verzonden en wordt het ontvangen antwoord geretourneerd. Als de bewerking niet is voltooid in de opgegeven time-out in milliseconden default: 60000, wordt OperationTimeoutError gegenereerd.

Constructordetails

RequestResponseLink(Session, Sender, Receiver)

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

Parameters

session

Session

De amqp-sessie.

sender

Sender

De koppeling naar de afzender amqp.

receiver

Receiver

De ontvangerkoppeling amqp.

Eigenschapdetails

connection

Biedt het onderliggende amqp-verbindingsobject.

Connection connection

Waarde van eigenschap

Connection

Verbinding.

receiver

receiver: Receiver

Waarde van eigenschap

Receiver

sender

sender: Sender

Waarde van eigenschap

Sender

session

session: Session

Waarde van eigenschap

Session

Methodedetails

close()

Hiermee sluit u de afzender, ontvangerkoppeling en de onderliggende sessie.

function close(): Promise<void>

Retouren

Promise<void>

Beloof<void>

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

Hiermee maakt u een amqp-aanvraag/antwoordkoppeling.

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

Parameters

connection

Connection

De amqp-verbinding.

senderOptions

SenderOptions

Opties die moeten worden opgegeven om de afzenderkoppeling te maken.

receiverOptions

ReceiverOptions

Opties die moeten worden opgegeven om de ontvangerkoppeling te maken.

createOptions

{ abortSignal?: AbortSignalLike }

Optionele parameters die kunnen worden gebruikt om het gedrag van deze methode te beïnvloeden. abortSignal kan bijvoorbeeld worden doorgegeven om het annuleren van een actieve create aanroep toe te staan.

Retouren

Promise<RequestResponseLink>

Beloof<RequestResponseLink>

isOpen()

Geeft aan of de sessie en de koppelingen van de afzender en ontvanger allemaal open of gesloten zijn.

function isOpen(): boolean

Retouren

boolean

Booleaanse waarde - true - open, false - closed.

remove()

Hiermee verwijdert u de afzender, ontvangerkoppeling en de onderliggende sessie.

function remove()

sendRequest(Message, SendRequestOptions)

Hiermee wordt het opgegeven aanvraagbericht verzonden en wordt het ontvangen antwoord geretourneerd. Als de bewerking niet is voltooid in de opgegeven time-out in milliseconden default: 60000, wordt OperationTimeoutError gegenereerd.

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

Parameters

request

Message

Het AMQP-bericht (aanvraag).

options

SendRequestOptions

Opties die kunnen worden opgegeven tijdens het verzenden van een aanvraag.

Retouren

Promise<Message>

Promise<Message> Het AMQP (response) bericht.