public class QueueRequestor extends ObjectSE
QueueRequestor ヘルパークラスは、サービスリクエストの作成を簡素化します。QueueRequestor コンストラクターには、トランザクションされていない QueueSession と宛先 Queue が与えられます。レスポンス用の TemporaryQueue を作成し、リクエストメッセージを送信してそのレスポンスを待機する request メソッドを提供します。
これは非常に基本的なリクエスト / 応答の抽象化であり、セッションが AUTO_ACKNOWLEDGE または DUPS_OK_ACKNOWLEDGE のいずれかの配信モードでトランザクションされていないことを前提としています。ほとんどのアプリケーションは、それほど基本的な実装を作成しないことが予想されます。
TopicRequestor| コンストラクターと説明 |
|---|
QueueRequestor(QueueSession session, Queue queue)QueueRequestor クラスのコンストラクター。 |
| 修飾子と型 | メソッドと説明 |
|---|---|
void | close()QueueRequestor とそのセッションを閉じます。 |
Message | request(Message message) リクエストを送信し、応答を待ちます。 |
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSEpublic QueueRequestor(QueueSession session, Queue queue) throws JMSException
QueueRequestor クラスのコンストラクター。 この実装では、セッションパラメーターが非トランザクションであり、配信モードが AUTO_ACKNOWLEDGE または DUPS_OK_ACKNOWLEDGE であると想定しています。
session - キューが属する QueueSession queue - リクエスト / 応答呼び出しを実行するキュー JMSException - 内部エラーが原因で Jakarta Messaging プロバイダーが QueueRequestor の作成に失敗した場合。InvalidDestinationException - 無効なキューが指定された場合。public Message request(Message message) throws JMSException
JMSReplyTo 宛先に使用され、リクエストごとに 1 つの応答のみが期待されます。message - 送信するメッセージ JMSException - 内部エラーが原因で Jakarta Messaging プロバイダーがリクエストを完了できない場合。public void close()
throws JMSExceptionQueueRequestor とそのセッションを閉じます。 プロバイダーは、Java 仮想マシンの外部で QueueRequestor に代わって一部のリソースを割り当てる可能性があるため、クライアントは、必要のないときに閉じる必要があります。最終的にこれらのリソースを再利用するためにガベージコレクションに依存することは、十分なタイムリーではない可能性があります。
このメソッドは、QueueRequestor コンストラクターに渡された QueueSession オブジェクトを閉じることに注意してください。
JMSException - 内部エラーが原因で Jakarta Messaging プロバイダーが QueueRequestor を閉じることができない場合。Copyright © 2018,2020 Eclipse Foundation.
Use is subject to license terms.