RequestResponseLink class
Popisuje odkaz amqp request(sender)-response(receiver) 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 nebo odpověď amqp. |
| is |
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. |
| 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<je neplatný>
create(Connection, SenderOptions, ReceiverOptions, { abortSignal?: AbortSignalLike })
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
Promise<RequestResponseLink>
Žádost o příslibResponseLink<>
isOpen()
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.
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, 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ěď).