| Package | Description |
|---|---|
| nablarch.fw.messaging |
メッセージング処理方式の実装に直接関連するモジュールを格納するパッケージ。
|
| nablarch.fw.messaging.action |
応答なし電文を受送信するアクションを提供する。
|
| Modifier and Type | Method and Description |
|---|---|
RequestMessage |
RequestMessage.setFormatterOfReply(DataRecordFormatter formatter)
応答電文のフォーマットを指定する。
|
RequestMessage |
RequestMessage.setRequestPath(java.lang.String requestPath)
リクエストパスを設定する。
|
| Constructor and Description |
|---|
ResponseMessage(RequestMessage message)
要求電文に対する応答電文を作成する。
RequestMessage#reply() から呼ばれることを想定している。
|
StructuredResponseMessage(RequestMessage message)
要求電文に対する応答電文を作成する。
RequestMessage#reply() から呼ばれることを想定している。
|
| Modifier and Type | Method and Description |
|---|---|
DataReader<RequestMessage> |
AsyncMessageReceiveAction.createReader(ExecutionContext ctx)
このタスクの入力データを読み込むデータリーダを生成して返す。
|
| Modifier and Type | Method and Description |
|---|---|
protected java.lang.Object |
AsyncMessageReceiveAction.createForm(java.lang.String requestId,
RequestMessage message)
受信テーブルにINSERTを行うためのFormオブジェクトを生成する。
生成するフォームクラスのクラス名は、パッケージ名:nablarch.fw.messaging.action.AsyncMessageReceiveActionSettings#getFormClassPackage()
から取得したパッケージ名、クラス名:リクエストID + "Form"となる。
また、Formクラスには下記引数を持つコンストラクタを定義し、受信メッセージの内容を保持すること。
String
受信メッセージ:RequestMessage
|
Result |
AsyncMessageReceiveAction.handle(RequestMessage inputData,
ExecutionContext ctx)
データリーダによって読み込まれた1件分の入力データに対する業務処理を実行する。
|
protected ResponseMessage |
MessagingAction.onError(java.lang.Throwable e,
RequestMessage request,
ExecutionContext context)
業務トランザクションが異常終了した場合の処理を実行する。
本メソッドは、業務トランザクションがロールバックされると起動される。
任意のエラー応答電文(
ResponseMessage)を返却したい場合は、本メソッドをオーバーライドすること。
デフォルト実装ではなにもしない。
注意:
以下のケースでは業務アクションへのディスパッチが行われる前にエラーが
発生するため、エラー応答電文の内容を制御することはできない。
フレームワーク制御ヘッダの形式不正
MOMミドルウェアのレイヤーで発生したエラー (JMSException等)
|
protected abstract ResponseMessage |
MessagingAction.onReceive(RequestMessage request,
ExecutionContext context)
要求電文毎にフレームワークから起動され、要求電文の内容をもとに業務処理を実行する。
|