RequestResponseLink class

Csomag:: @azure/core-amqp

A cikk egy amqp-munkameneten keresztül létrehozott amqp-request(sender)-response(receiver) hivatkozást ismerteti.

Konstruktorok

RequestResponseLink(Session, Sender, Receiver)

Tulajdonságok

connection	A mögöttes amqp kapcsolatobjektumot adja meg.
receiver
sender
session

Metódusok

close()	Bezárja a feladót, a fogadó hivatkozást és a mögöttes munkamenetet.
create(Connection, SenderOptions, ReceiverOptions, { abortSignal?: AbortSignalLike })	Létrehoz egy amqp-kérés-/válaszhivatkozást.
isOpen()	Azt jelzi, hogy a munkamenet, valamint a feladó és a fogadó hivatkozásai mind nyitottak vagy bezárva vannak-e.
remove()	Eltávolítja a feladót, a fogadó hivatkozást és a mögöttes munkamenetet.
sendRequest(Message, SendRequestOptions)	Elküldi a megadott kérésüzenetet, és visszaadja a kapott választ. Ha a művelet nem fejeződik be a megadott időtúllépésben ezredmásodpercben `default: 60000`, akkor `OperationTimeoutError` lesz dobva.

Konstruktor adatai

RequestResponseLink(Session, Sender, Receiver)

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

Paraméterek

session: Session

Az amqp munkamenet.

sender: Sender

Az amqp feladó hivatkozása.

receiver: Receiver

Az amqp-fogadó hivatkozása.

Tulajdonság adatai

connection

A mögöttes amqp kapcsolatobjektumot adja meg.

Connection connection

Tulajdonság értéke

Connection

Kapcsolat.

receiver

receiver: Receiver

Tulajdonság értéke

Receiver

sender

sender: Sender

Tulajdonság értéke

Sender

session

session: Session

Tulajdonság értéke

Session

Metódus adatai

close()

Bezárja a feladót, a fogadó hivatkozást és a mögöttes munkamenetet.

function close(): Promise<void>

Válaszok

Promise<void>

Ígéret<érvénytelen>

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

Létrehoz egy amqp-kérés-/válaszhivatkozást.

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

Paraméterek

connection: Connection

Az amqp-kapcsolat.

senderOptions: SenderOptions

A feladó hivatkozásának létrehozásához meg kell adni a beállításokat.

receiverOptions: ReceiverOptions

A fogadóhivatkozás létrehozásához meg kell adni a beállításokat.

createOptions: { abortSignal?: AbortSignalLike }

Nem kötelező paraméterek, amelyek a metódus viselkedésének befolyásolására használhatók. Például abortSignal továbbíthatók a folyamatban lévő create hívás megszakításának engedélyezéséhez.

Válaszok

Promise<RequestResponseLink>

Ígéret<RequestResponseLink>

isOpen()

Azt jelzi, hogy a munkamenet, valamint a feladó és a fogadó hivatkozásai mind nyitottak vagy bezárva vannak-e.

function isOpen(): boolean

Válaszok

boolean

logikai - true - open, false - closed.

remove()

Eltávolítja a feladót, a fogadó hivatkozást és a mögöttes munkamenetet.

function remove()

sendRequest(Message, SendRequestOptions)

Elküldi a megadott kérésüzenetet, és visszaadja a kapott választ. Ha a művelet nem fejeződik be a megadott időtúllépésben ezredmásodpercben default: 60000, akkor OperationTimeoutError lesz dobva.

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

Paraméterek

request: Message

Az AMQP (kérés) üzenet.

options: SendRequestOptions

A kérés elküldése során megadható beállítások.

Válaszok

Promise<Message>

Ígéretüzenet<> Az AMQP (válasz) üzenet.