クラス QueueSend_MQ

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

public class QueueSend_MQ extends Object implements QueueSend
MQサーバへのメッセージキュー送信用クラス MQサーバへのメッセージキュー送信用のクラスです。 Apache ActiveMQとAmazonMQへの送信が可能です。 tomcatからの送信(JNDI利用)と、 バッチ処理(urlを指定し接続)の2通りが可能です。 ※Apache ActiveMQとAmazonMQの切り替えは、 jmsServerの接続先URLを変更するのみで接続の変更が可能です。 (proxy環境からAmazonMqへの接続は行えない場合があります)
変更履歴:
5.10.14.0 (2019/08/01) 新規作成
機能分類
メッセージ連携
導入されたバージョン:
JDK7
  • コンストラクタの概要

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

    修飾子とタイプ
    メソッド
    説明
    void
    クローズ処理 MQサーバとの接続をクローズします。
    void
    connect(String jmsServer)
    接続処理 MQサーバに接続を行います。
    void
    connect(String jmsServer, String sqsAccessKey, String sqsSecretKey)
    接続処理 MQサーバに接続します。
    static void
    main(String[] args)
    テスト用メソッド テスト実行用です。
    void
    メッセージ送信 MQサーバにメッセージを送信します。
    void
    setBatchFlg(Boolean batchFlg)
    バッチ処理判定フラグを設定します。
    void
    エラーメッセージ送信。

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

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

  • メソッドの詳細

    • connect

      public void connect(String jmsServer)
      接続処理 MQサーバに接続を行います。
      パラメータ:
      jmsServer - jmsサーバ接続名(バッチの場合はurl)
    • connect

      public void connect(String jmsServer, String sqsAccessKey, String sqsSecretKey)
      接続処理 MQサーバに接続します。 connect(String jmsServer)と同じ処理になります。
      定義:
      connect インタフェース内 QueueSend
      パラメータ:
      jmsServer - jmsサーバ情報
      sqsAccessKey - アクセスキー(MQサーバでは未使用)
      sqsSecretKey - シークレットキー(MQサーバでは未使用)
      変更履歴:
      5.10.15.0 (2019/08/30) 引数追加対応
    • throwErrMsg

      public void throwErrMsg(String errMsg)
      エラーメッセージ送信。
      パラメータ:
      errMsg - エラーメッセージ
      変更履歴:
      5.10.15.0 (2019/08/30) Hybs除外
    • sendMessage

      public void sendMessage(QueueInfo queueInfo)
      メッセージ送信 MQサーバにメッセージを送信します。
      定義:
      sendMessage インタフェース内 QueueSend
      パラメータ:
      queueInfo - 送信キュー情報
    • close

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

      public void setBatchFlg(Boolean batchFlg)
      バッチ処理判定フラグを設定します。 バッチ処理の場合は引数で接続先情報を与えます。 それ以外の場合(Tomcat)ではJNDIより情報を取得します。
      定義:
      setBatchFlg インタフェース内 QueueSend
      パラメータ:
      batchFlg - バッチ処理判定フラグ
    • main

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