Sdílet prostřednictvím


RequestResponseLink class

Popisuje odkaz amqp request(sender)-response(receiver) 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 nebo odpověď amqp.

isOpen()

Určuje, jestli jsou relace a odkazy odesílatele a příjemce otevřené nebo uzavř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, OperationTimeoutError je 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<je neplatný>

Vytvoří odkaz na požadavek nebo 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 k vytvoření odkazu 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. Například abortSignal lze předat, aby bylo možné zrušit probíhající create vyvolání.

Návraty

Žádost o příslibResponseLink<>

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

function isOpen(): boolean

Návraty

boolean

boolean - 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, OperationTimeoutError je vyvolána.

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

Parametry

request

Message

Zpráva AMQP (požadavek).

options
SendRequestOptions

Možnosti, které lze zadat při odesílání požadavku.

Návraty

Promise<Message>

Zpráva příslibu<> Zpráva AMQP (odpověď).