RequestResponseLink class
Popisuje odkaz amqp request(sender)-response(receiver), který je vytvořen v relaci amqp.
Konstruktory
Request |
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, Sender |
Vytvoří odkaz na požadavek a odpověď amqp. |
is |
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. |
send |
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 |
Podrobnosti konstruktoru
RequestResponseLink(Session, Sender, Receiver)
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
connection
Poskytuje základní objekt připojení amqp.
Connection connection
Hodnota vlastnosti
Connection
Připojení.
receiver
receiver: Receiver
Hodnota vlastnosti
Receiver
sender
sender: Sender
Hodnota vlastnosti
Sender
session
session: Session
Hodnota vlastnosti
Session
Podrobnosti metody
close()
Zavře odesílatele, odkaz příjemce a podkladovou relaci.
function close(): Promise<void>
Návraty
Promise<void>
Slib
create(Connection, SenderOptions, ReceiverOptions, { abortSignal?: AbortSignalLike })
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
Promise<RequestResponseLink>
Slib
isOpen()
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
remove()
Odebere odesílatele, odkaz příjemce a jeho podkladovou relaci.
function remove()
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.
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ěď).