nablarch.test.core.messaging

クラス AsyncMessageSendActionForUt

java.lang.Object

nablarch.core.db.support.DbAccessSupport

nablarch.fw.action.BatchActionBase<D>

nablarch.fw.action.BatchAction<SqlRow>

nablarch.fw.messaging.action.AsyncMessageSendAction

nablarch.test.core.messaging.AsyncMessageSendActionForUt

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

DataReaderFactory<SqlRow>, Handler<SqlRow,Result>, ExecutionHandlerCallback<CommandLine,Result>, TransactionEventCallback<SqlRow>

public class AsyncMessageSendActionForUt
extends AsyncMessageSendAction

リクエスト単体テスト用のメッセージ送信（応答なし）アクション。

本クラスは、バッチ起動引数で「errorCase=true」が指定された場合に、 例外を送出し異常系のテストとして処理を行う。

バッチ起動引数でerrorCaseが指定されていない場合や、errorCaseがfalseの場合には、 AsyncMessageSendActionに処理を委譲する。

ネストされたクラスのサマリー

インタフェースから継承されたネストされたクラス/インタフェース nablarch.fw.TransactionEventCallback

TransactionEventCallback.Provider<TData>

フィールドのサマリー

インタフェースから継承されたフィールド nablarch.fw.TransactionEventCallback

REQUEST_DATA_REQUEST_SCOPE_KEY

コンストラクタのサマリー

コンストラクタ

コンストラクタと説明
AsyncMessageSendActionForUt()

メソッドのサマリー

修飾子とタイプ	メソッドと説明
Result	handle(SqlRow inputData, ExecutionContext ctx) 入力データからヘッダ部及び業務データ部からなるメッセージオブジェクトを生成し、 送信処理（キューへのPUT）を行う。
protected void	initialize(CommandLine command, ExecutionContext context) 初期処理を行う。

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

createDataRecordFormatter, createFormInstance, createHeaderRecord, createHeaderRecordFormatter, createReader, createStatement, getFormatDir, getHeaderFormatName, getQueueName, getSettings, getSqlResource, transactionAbnormalEnd, transactionNormalEnd, updateStatus

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

error, errorInExecution, postExecution, preExecution, terminate, transactionFailure, transactionSuccess, writeErrorLog, writeFatalLog, writeLog

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

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

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

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

コンストラクタの詳細

AsyncMessageSendActionForUt

public AsyncMessageSendActionForUt()

メソッドの詳細

initialize

protected void initialize(CommandLine command,
                          ExecutionContext context)

クラスからコピーされた説明: AsyncMessageSendAction

初期処理を行う。

起動引数から送信対象のメッセージのリクエストIDを取得し、保持する。

オーバーライド:

initialize クラス内 AsyncMessageSendAction

パラメータ:

command - 起動コマンドライン

context - 実行コンテキスト

handle

public Result handle(SqlRow inputData,
                     ExecutionContext ctx)

クラスからコピーされた説明: AsyncMessageSendAction

入力データからヘッダ部及び業務データ部からなるメッセージオブジェクトを生成し、 送信処理（キューへのPUT）を行う。

処理詳細は、以下のとおり。

1. ヘッダ部は、AsyncMessageSendAction.createHeaderRecord(nablarch.core.db.statement.SqlRow)で生成する。
2. 業務データ部は、インプットデータ(本メソッドの引数)をそのまま使用する。
3. 送信先のキューは、AsyncMessageSendAction.getQueueName()から取得する。

定義:

handle インタフェース内 Handler<SqlRow,Result>

オーバーライド:

handle クラス内 AsyncMessageSendAction

パラメータ:

inputData - 入力データ

ctx - 実行コンテキスト

戻り値:

処理結果情報オブジェクト