Sdílet prostřednictvím


RequestResponseLink class

Popisuje odkaz amqp request(sender)-response(receiver), který je vytvořen v relaci amqp.

Konstruktory

RequestResponseLink(Session, Sender, Receiver)

Vlastnosti

connection

Poskytuje základní objekt připojení amqp.

receiver
sender
session

Metody

close()

Zavře odesílatele, odkaz příjemce a podkladovou relaci.

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

Vytvoří odkaz na požadavek a odpověď amqp.

isOpen()

Určuje, jestli jsou relace a odkazy odesílatele a příjemce otevřené nebo zavřené.

remove()

Odebere odesílatele, odkaz příjemce a jeho podkladovou relaci.

sendRequest(Message, SendRequestOptions)

Odešle danou zprávu požadavku a vrátí přijatou odpověď. Pokud operace není dokončena v zadaném časovém limitu v milisekundách default: 60000, je OperationTimeoutError vyvolána.

Podrobnosti konstruktoru

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

Parametry

session

Session

Relace amqp.

sender

Sender

Odkaz odesílatele amqp

receiver

Receiver

Odkaz přijímače amqp.

Podrobnosti vlastnosti

Poskytuje základní objekt připojení amqp.

Connection connection

Hodnota vlastnosti

Connection

Připojení.

receiver: Receiver

Hodnota vlastnosti

Receiver

sender: Sender

Hodnota vlastnosti

Sender

session: Session

Hodnota vlastnosti

Session

Podrobnosti metody

Zavře odesílatele, odkaz příjemce a podkladovou relaci.

function close(): Promise<void>

Návraty

Promise<void>

Slib

Vytvoří odkaz na požadavek a odpověď amqp.

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

Parametry

connection

Connection

Připojení amqp.

senderOptions

SenderOptions

Možnosti, které je nutné zadat, aby bylo možné vytvořit odkaz odesílatele.

receiverOptions

ReceiverOptions

Možnosti, které musí být poskytnuty k vytvoření odkazu příjemce.

createOptions

{ abortSignal?: AbortSignalLike }

Volitelné parametry, které lze použít k ovlivnění chování této metody. Může se například předat, abortSignal aby bylo možné zrušit probíhající create vyvolání.

Návraty

Slib

Určuje, jestli jsou relace a odkazy odesílatele a příjemce otevřené nebo zavřené.

function isOpen(): boolean

Návraty

boolean

logická hodnota – true - open, . false - closed

Odebere odesílatele, odkaz příjemce a jeho podkladovou relaci.

function remove()

Odešle danou zprávu požadavku a vrátí přijatou odpověď. Pokud operace není dokončena v zadaném časovém limitu v milisekundách default: 60000, je OperationTimeoutError vyvolána.

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

Parametry

request

Message

Zpráva AMQP (požadavek).

options
SendRequestOptions

Možnosti, které je možné zadat při odesílání žádosti.

Návraty

Promise<Message>

Slibte zprávu AMQP (odpověď).