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>
リクエスト単体テスト用のメッセージ送信(応答なし)アクション。
本クラスは、バッチ起動引数で「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
-
Method Summary
Modifier and TypeMethodDescriptionhandle
(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
-
Constructor Details
-
AsyncMessageSendActionForUt
public AsyncMessageSendActionForUt()
-
-
Method Details
-
initialize
Description copied from class:AsyncMessageSendAction
初期処理を行う。 起動引数から送信対象のメッセージのリクエストIDを取得し、保持する。- Overrides:
initialize
in classAsyncMessageSendAction
- Parameters:
command
- 起動コマンドラインcontext
- 実行コンテキスト
-
handle
Description copied from class:AsyncMessageSendAction
入力データからヘッダ部及び業務データ部からなるメッセージオブジェクトを生成し、 送信処理(キューへのPUT)を行う。 処理詳細は、以下のとおり。- ヘッダ部は、
AsyncMessageSendAction.createHeaderRecord(nablarch.core.db.statement.SqlRow)
で生成する。 - 業務データ部は、インプットデータ(本メソッドの引数)をそのまま使用する。
- 送信先のキューは、
AsyncMessageSendAction.getQueueName()
から取得する。
- ヘッダ部は、
-