パッケージ jakarta.jms

クラス QueueRequestor

java.lang.ObjectSE
jakarta.jms.QueueRequestor
public class QueueRequestor extends ObjectSE
QueueRequestor ヘルパークラスは、サービスリクエストの作成を簡素化します。

QueueRequestor コンストラクターには、トランザクションされていない QueueSession と宛先 Queue が与えられます。レスポンス用の TemporaryQueue を作成し、リクエストメッセージを送信してそのレスポンスを待機する request メソッドを提供します。

これは非常に基本的なリクエスト / 応答の抽象化であり、セッションが AUTO_ACKNOWLEDGE または DUPS_OK_ACKNOWLEDGE のいずれかの配信モードでトランザクションされていないことを前提としています。ほとんどのアプリケーションは、それほど基本的な実装を作成しないことが予想されます。

導入:
JMS 1.0
バージョン:
Jakarta Messaging 2.0
関連事項:

  • コンストラクターの詳細

    • QueueRequestor

      public QueueRequestor(QueueSession session, Queue queue) throws JMSException
      QueueRequestor クラスのコンストラクター。

      この実装では、セッションパラメーターが非トランザクションであり、配信モードが AUTO_ACKNOWLEDGE または DUPS_OK_ACKNOWLEDGE であると想定しています。

      パラメーター:
      session - キューが属する QueueSession 
      queue - リクエスト / 応答呼び出しを実行するキュー
      例外:
      JMSException - 内部エラーが原因で Jakarta Messaging プロバイダーが QueueRequestor の作成に失敗した場合。
      InvalidDestinationException - 無効なキューが指定された場合。

  • メソッドの詳細

    • request

      public Message request(Message message) throws JMSException
      リクエストを送信し、返信を待ちます。一時キューは JMSReplyTo 宛先に使用され、リクエストごとに 1 つの応答のみが期待されます。
      パラメーター:
      message - 送信するメッセージ
      戻り値:
      返信メッセージ
      例外:
      JMSException - 内部エラーが原因で Jakarta Messaging プロバイダーがリクエストを完了できない場合。

    • close

      public void close() throws JMSException
      QueueRequestor とそのセッションを閉じます。

      プロバイダーは、Java 仮想マシンの外部で QueueRequestor に代わって一部のリソースを割り当てる可能性があるため、クライアントは、必要のないときに閉じる必要があります。最終的にこれらのリソースを再利用するためにガベージコレクションに依存することは、十分なタイムリーではない可能性があります。

      このメソッドは、QueueRequestor コンストラクターに渡された QueueSession オブジェクトを閉じることに注意してください。

      例外:
      JMSException - 内部エラーが原因で Jakarta Messaging プロバイダーが QueueRequestor を閉じることができない場合。