Package nablarch.test.core.messaging

Class 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

All Implemented Interfaces:

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

public class AsyncMessageSendActionForUt
extends AsyncMessageSendAction

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

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

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

Nested Class Summary

Nested classes/interfaces inherited from interface nablarch.fw.TransactionEventCallback

TransactionEventCallback.Provider<TData>

Field Summary

Fields inherited from interface nablarch.fw.TransactionEventCallback

REQUEST_DATA_REQUEST_SCOPE_KEY

Constructor Summary

Constructors

Constructor	Description
AsyncMessageSendActionForUt()

Method Summary

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

Methods inherited from class nablarch.fw.messaging.action.AsyncMessageSendAction

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

Methods inherited from class nablarch.fw.action.BatchActionBase

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

Methods inherited from class nablarch.core.db.support.DbAccessSupport

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

Methods inherited from class java.lang.Object

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

Constructor Details

AsyncMessageSendActionForUt

public AsyncMessageSendActionForUt()

Method Details

initialize

protected void initialize(CommandLine command,
 ExecutionContext context)

Description copied from class: AsyncMessageSendAction

初期処理を行う。

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

Overrides:

initialize in class AsyncMessageSendAction

Parameters:

command - 起動コマンドライン

context - 実行コンテキスト

handle

public Result handle(SqlRow inputData,
 ExecutionContext ctx)

Description copied from class: AsyncMessageSendAction

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

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

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

Specified by:

handle in interface Handler<SqlRow,Result>

Overrides:

handle in class AsyncMessageSendAction

Parameters:

inputData - 入力データ

ctx - 実行コンテキスト

Returns:

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