nablarch.fw.messaging.action

クラス AsyncMessageSendAction

java.lang.Object

nablarch.core.db.support.DbAccessSupport

nablarch.fw.action.BatchActionBase<D>

nablarch.fw.action.BatchAction<SqlRow>

nablarch.fw.messaging.action.AsyncMessageSendAction

すべての実装されたインタフェース:

nablarch.fw.DataReaderFactory<SqlRow>, nablarch.fw.Handler<SqlRow,Result>, nablarch.fw.handler.ExecutionHandlerCallback<CommandLine,Result>, nablarch.fw.TransactionEventCallback<SqlRow>

@Published(tag="architect")
public class AsyncMessageSendAction
extends BatchAction<SqlRow>

MQ応答なし送信用の共通アクション。

本クラスでは、送信用のテーブル（一時テーブル）から送信対象のデータを取得し、メッセージを送信する。

送信対象のメッセージのリクエストIDは、本バッチの起動時の引数(起動パラメータ名:messageRequestId)として指定すること。

送信対象のデータを抽出するSQL文は、テーブル単位に用意する必要がある。 詳細は、nablarch.fw.messaging.action.AsyncMessageSendAction#createStatement()を参照

メッセージが正常に送信できた場合には、#transactionNormalEnd(nablarch.core.db.statement.SqlRow, nablarch.fw.ExecutionContext)にて 対象データのステータスを処理済みに更新する。

メッセージ送信時に例外が発生した場合には、#transactionAbnormalEnd(Throwable, nablarch.core.db.statement.SqlRow, nablarch.fw.ExecutionContext)にて 対象データのステータスをエラーに更新する。

作成者:

hisaaki sioiri

メソッドのサマリー

クラスから継承されたメソッド nablarch.fw.action.BatchAction

createReader, handle

クラスから継承されたメソッド nablarch.fw.action.BatchActionBase

error, initialize, terminate, transactionFailure, transactionSuccess, writeErrorLog, writeFatalLog, writeLog

クラスから継承されたメソッド nablarch.core.db.support.DbAccessSupport

countByParameterizedSql, countByStatementSql, getParameterizedSqlStatement, getParameterizedSqlStatement, getSqlCStatement, getSqlPStatement, search