RequestResponseLink class
amqp セッションを介して作成される amqp request(sender)-response(receiver) リンクについて説明します。
プロパティ
| connection | 基になる amqp 接続オブジェクトを提供します。 |
| receiver | |
| sender | |
| session |
メソッド
| close() | 送信側、受信側のリンク、および基になるセッションを閉じます。 |
| create(Connection, Sender |
amqp 要求/応答リンクを作成します。 |
| is |
セッションと送信者と受信者のリンクがすべて開いているか閉じているかを示します。 |
| remove() | 送信者、受信者のリンク、および基になるセッションを削除します。 |
| send |
指定された要求メッセージを送信し、受信した応答を返します。 指定されたタイムアウトで操作が完了しなかった場合 (ミリ秒 |
コンストラクターの詳細
RequestResponseLink(Session, Sender, Receiver)
new RequestResponseLink(session: Session, sender: Sender, receiver: Receiver)パラメーター
- session
-
Session
amqp セッション。
- sender
-
Sender
amqp 送信者のリンク。
- receiver
-
Receiver
amqp レシーバー リンク。
プロパティの詳細
connection
基になる amqp 接続オブジェクトを提供します。
Connection connectionプロパティ値
Connection
接続。
receiver
receiver: Receiverプロパティ値
Receiver
sender
sender: Senderプロパティ値
Sender
session
session: Sessionプロパティ値
Session
メソッドの詳細
close()
送信側、受信側のリンク、および基になるセッションを閉じます。
function close(): Promise<void>戻り値
Promise<void>
約束<無効>
create(Connection, SenderOptions, ReceiverOptions, { abortSignal?: AbortSignalLike })
amqp 要求/応答リンクを作成します。
static function create(connection: Connection, senderOptions: SenderOptions, receiverOptions: ReceiverOptions, createOptions?: { abortSignal?: AbortSignalLike }): Promise<RequestResponseLink>パラメーター
- connection
-
Connection
amqp 接続。
- senderOptions
-
SenderOptions
送信者リンクを作成するために指定する必要があるオプション。
- receiverOptions
-
ReceiverOptions
受信側リンクを作成するために指定する必要があるオプション。
- createOptions
-
{ abortSignal?: AbortSignalLike }
このメソッドの動作に影響を与えるために使用できる省略可能なパラメーター。
たとえば、abortSignal を渡して、進行中の create 呼び出しを取り消すことができます。
戻り値
Promise<RequestResponseLink>
Promise<RequestResponseLink>
isOpen()
セッションと送信者と受信者のリンクがすべて開いているか閉じているかを示します。
function isOpen(): boolean戻り値
boolean
boolean - true - open、 false - closed。
remove()
送信者、受信者のリンク、および基になるセッションを削除します。
function remove()
sendRequest(Message, SendRequestOptions)
指定された要求メッセージを送信し、受信した応答を返します。 指定されたタイムアウトで操作が完了しなかった場合 (ミリ秒 default: 60000)、OperationTimeoutError がスローされます。
function sendRequest(request: Message, options?: SendRequestOptions): Promise<Message>パラメーター
- request
-
Message
AMQP (要求) メッセージ。
- options
- SendRequestOptions
要求の送信中に指定できるオプション。
戻り値
Promise<Message>
Promise<Message> AMQP (応答) メッセージ。