パッケージ org.opengion.fukurou.queue

# クラス 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を指定し接続)の２通りが可能です。 ※Apache ActiveMQとAmazonMQの切り替えは、 jmsServerの接続先URLを変更するのみで接続の変更が可能です。 (proxy環境からAmazonMqへの接続は行えない場合があります)

変更履歴:
  5.10.14.0 (2019/08/01) 新規作成
機能分類
  メッセージ連携
導入されたバージョン:
  JDK7

- ## コンストラクタの概要

  コンストラクタ
  コンストラクタ
  説明
  `QueueSend_MQ()`

- ## メソッドの概要

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

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

  `clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait`

- ## コンストラクタの詳細

  - ### QueueSend_MQ

    public QueueSend_MQ()

- ## メソッドの詳細

  - ### 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` - 引数