RequestResponseLink class
amqp セッションを介して作成される amqp request(sender)-response(receiver) リンクについて説明します。
コンストラクター
| Request |
プロパティ
| 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>
Promise
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
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 AMQP (応答) メッセージ。