public class AsyncMessageSendActionForUt extends AsyncMessageSendAction
AsyncMessageSendActionに処理を委譲する。TransactionEventCallback.Provider<TData>REQUEST_DATA_REQUEST_SCOPE_KEY| Constructor and Description |
|---|
AsyncMessageSendActionForUt() |
| Modifier and Type | Method and Description |
|---|---|
Result |
handle(SqlRow inputData,
ExecutionContext ctx)
入力データからヘッダ部及び業務データ部からなるメッセージオブジェクトを生成し、
送信処理（キューへのPUT）を行う。
処理詳細は、以下のとおり。
ヘッダ部は、
AsyncMessageSendAction.createHeaderRecord(nablarch.core.db.statement.SqlRow)で生成する。
業務データ部は、インプットデータ(本メソッドの引数)をそのまま使用する。
送信先のキューは、AsyncMessageSendAction.getQueueName()から取得する。
|
protected void |
initialize(CommandLine command,
ExecutionContext context)
初期処理を行う。
起動引数から送信対象のメッセージのリクエストIDを取得し、保持する。
|
createDataRecordFormatter, createFormInstance, createHeaderRecord, createHeaderRecordFormatter, createReader, createStatement, getFormatDir, getHeaderFormatName, getQueueName, getSettings, getSqlResource, transactionAbnormalEnd, transactionNormalEnd, updateStatuserror, errorInExecution, postExecution, preExecution, terminate, transactionFailure, transactionSuccess, writeErrorLog, writeFatalLog, writeLogcountByParameterizedSql, countByStatementSql, getParameterizedSqlStatement, getParameterizedSqlStatement, getSqlCStatement, getSqlPStatement, searchprotected void initialize(CommandLine command, ExecutionContext context)
AsyncMessageSendActioninitialize in class AsyncMessageSendActioncommand - 起動コマンドラインcontext - 実行コンテキストpublic Result handle(SqlRow inputData, ExecutionContext ctx)
AsyncMessageSendActionAsyncMessageSendAction.createHeaderRecord(nablarch.core.db.statement.SqlRow)で生成する。AsyncMessageSendAction.getQueueName()から取得する。