public class AsyncMessageSendActionForUt extends AsyncMessageSendAction
AsyncMessageSendAction
に処理を委譲する。TransactionEventCallback.Provider<TData>
REQUEST_DATA_REQUEST_SCOPE_KEY
コンストラクタと説明 |
---|
AsyncMessageSendActionForUt() |
修飾子とタイプ | メソッドと説明 |
---|---|
Result |
handle(SqlRow inputData,
ExecutionContext ctx)
入力データからヘッダ部及び業務データ部からなるメッセージオブジェクトを生成し、
送信処理(キューへのPUT)を行う。
|
protected void |
initialize(CommandLine command,
ExecutionContext context)
初期処理を行う。
|
createDataRecordFormatter, createFormInstance, createHeaderRecord, createHeaderRecordFormatter, createReader, createStatement, getFormatDir, getHeaderFormatName, getQueueName, getSettings, getSqlResource, transactionAbnormalEnd, transactionNormalEnd, updateStatus
error, errorInExecution, postExecution, preExecution, terminate, transactionFailure, transactionSuccess, writeErrorLog, writeFatalLog, writeLog
countByParameterizedSql, countByStatementSql, getParameterizedSqlStatement, getParameterizedSqlStatement, getSqlCStatement, getSqlPStatement, search
protected void initialize(CommandLine command, ExecutionContext context)
AsyncMessageSendAction
initialize
クラス内 AsyncMessageSendAction
command
- 起動コマンドラインcontext
- 実行コンテキストpublic Result handle(SqlRow inputData, ExecutionContext ctx)
AsyncMessageSendAction
AsyncMessageSendAction.createHeaderRecord(nablarch.core.db.statement.SqlRow)
で生成する。AsyncMessageSendAction.getQueueName()
から取得する。