クラス QueueReceive_MQ

java.lang.Object
org.opengion.fukurou.queue.QueueReceive_MQ
すべての実装されたインタフェース:
QueueReceive

public class QueueReceive_MQ extends Object implements QueueReceive
MQメッセージ受信用クラス。
変更履歴:
5.10.15.2 (2019/09/20) 新規作成
機能分類
メッセージ連携
導入されたバージョン:
JDK7
  • コンストラクタの概要

    コンストラクタ
    コンストラクタ
    説明
     
  • メソッドの概要

    修飾子とタイプ
    メソッド
    説明
    void
    クローズ処理 クローズ処理を行います。
    void
    クローズリスナー レシーバーをクローズすることで、 リスナーの処理を終了します。
    void
    connect(String jmsServer, String sqsAccessKey, String sqsSecretKey)
    接続処理 メッセージキューサーバに接続します。
    static void
    main(String[] args)
    検証用メソッド テスト用のメソッドです。
    receive(String queueName)
    受信処理 メッセージキューの受信の処理を行います。
    void
    setBatchFlg(Boolean batchFlg)
    バッチ処理判定フラグを設定します。
    void
    setListener(String queueName, javax.jms.MessageListener listener)
    リスナーの起動 指定したキュー名に対して、 MessageListenerのリスナーを設定します。

    クラスから継承されたメソッド java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
  • コンストラクタの詳細

  • メソッドの詳細

    • connect

      public void connect(String jmsServer, String sqsAccessKey, String sqsSecretKey)
      接続処理 メッセージキューサーバに接続します。
      定義:
      connect インタフェース内 QueueReceive
      パラメータ:
      jmsServer - jsmサーバ
      sqsAccessKey - sqs用awsアクセスキー(MQでは利用しません)
      sqsSecretKey - sqs用awsシークレットキー(MQでは利用しません)
    • receive

      public QueueInfo receive(String queueName)
      受信処理 メッセージキューの受信の処理を行います。
      定義:
      receive インタフェース内 QueueReceive
      パラメータ:
      queueName - キューの名前
      戻り値:
      キュー情報格納クラス
    • setListener

      public void setListener(String queueName, javax.jms.MessageListener listener)
      リスナーの起動 指定したキュー名に対して、 MessageListenerのリスナーを設定します。
      定義:
      setListener インタフェース内 QueueReceive
      パラメータ:
      queueName - キュー名
      listener - MessageListerを実装したクラス
    • closeListener

      public void closeListener()
      クローズリスナー レシーバーをクローズすることで、 リスナーの処理を終了します。
      定義:
      closeListener インタフェース内 QueueReceive
    • close

      public void close()
      クローズ処理 クローズ処理を行います。
      定義:
      close インタフェース内 QueueReceive
      変更履歴:
      8.0.0.0 (2021/07/31) Avoid catching generic exceptions such as Exception in try-catch block
    • setBatchFlg

      public void setBatchFlg(Boolean batchFlg)
      バッチ処理判定フラグを設定します。
      定義:
      setBatchFlg インタフェース内 QueueReceive
      パラメータ:
      batchFlg - バッチ処理判定フラグ
    • main

      public static void main(String[] args)
      検証用メソッド テスト用のメソッドです。
      パラメータ:
      args - 引数