Package | Description |
---|---|
nablarch.fw.messaging |
メッセージング処理方式の実装に直接関連するモジュールを格納するパッケージ。
|
nablarch.fw.messaging.realtime.http.client |
HTTPを用いたメッセージング処理方式の実装に直接関連するモジュールを格納するパッケージ。
|
Modifier and Type | Method and Description |
---|---|
SyncMessage |
SyncMessage.addDataRecord(java.util.Map dataRecord)
データレコードを追加する。
|
SyncMessage |
SyncMessage.addDataRecord(java.lang.Object form)
データレコードを追加する。
|
SyncMessage |
SyncMessageConvertor.convertOnReceiveSync(MessageSenderSettings settings,
SyncMessage requestMessage,
SendingMessage sendingMessage,
ReceivedMessage receivedMessage)
受信電文を応答電文に変換する。(受信時)
|
SyncMessage |
MessageSenderClient.sendSync(MessageSenderSettings settings,
SyncMessage requestMessage)
同期通信を行う。
|
static SyncMessage |
MessageSender.sendSync(SyncMessage requestMessage)
対外システムにメッセージを送信し、応答された電文を返す。
電文の設定情報について
MessageSenderSettings.MessageSenderSettings(String) を実行して、対象リクエストの設定情報を取得する。
要求電文の作成について要求電文の作成処理は SyncMessageConvertor に委譲する。
SyncMessageConvertorの取得方法は、MessageSender.getSyncMessageConvertor(MessageSenderSettings) メソッドのJavaDocを参照。
デフォルトでは、フレームワークが提供するSyncMessageConvertorをそのまま使用する。
メッセージの再送についてキューを使用した通信では、設定によりリトライ回数が指定されている場合、 タイムアウト発生時に指定された回数まで再送を行う。 HTTP通信では再送を行わない。 メッセージ送受信中にエラーが発生した場合、 SyncMessagingEventHook にエラー処理を委譲する。
SyncMessagingEventHookの設定方法はMessageSenderSettings.MessageSenderSettings(String) のJavaDocを参照。 |
SyncMessage |
SyncMessage.setHeaderRecord(java.util.Map headerRecord)
ヘッダレコードを設定する。
|
Modifier and Type | Method and Description |
---|---|
void |
SyncMessagingEventHook.afterSend(MessageSenderSettings settings,
SyncMessage requestMessage,
SyncMessage responseMessage)
メッセージ送信後、レスポンスを受け取った後に呼ばれる処理。
|
void |
SyncMessagingEventHook.beforeSend(MessageSenderSettings settings,
SyncMessage requestMessage)
メッセージ送信前に呼ばれる処理。
|
SyncMessage |
SyncMessageConvertor.convertOnReceiveSync(MessageSenderSettings settings,
SyncMessage requestMessage,
SendingMessage sendingMessage,
ReceivedMessage receivedMessage)
受信電文を応答電文に変換する。(受信時)
|
SendingMessage |
SyncMessageConvertor.convertOnRetry(MessageSenderSettings settings,
SyncMessage requestMessage,
SendingMessage timeoutMessage,
int retryCount)
要求電文を送信電文に変換する。(再送時)
|
SendingMessage |
SyncMessageConvertor.convertOnSendSync(MessageSenderSettings settings,
SyncMessage requestMessage)
要求電文を送信電文に変換する。(初回送信時)
|
protected SendingMessage |
SyncMessageConvertor.createSendingMessage(MessageSenderSettings settings,
SyncMessage requestMessage)
指定された設定情報をもとに送信電文を作成する。
|
boolean |
SyncMessagingEventHook.onError(java.lang.RuntimeException e,
boolean hasNext,
MessageSenderSettings settings,
SyncMessage requestMessage,
SyncMessage responseMessage)
メッセージ送信中のエラー発生時に呼ばれる処理。
|
SyncMessage |
MessageSenderClient.sendSync(MessageSenderSettings settings,
SyncMessage requestMessage)
同期通信を行う。
|
static SyncMessage |
MessageSender.sendSync(SyncMessage requestMessage)
対外システムにメッセージを送信し、応答された電文を返す。
電文の設定情報について
MessageSenderSettings.MessageSenderSettings(String) を実行して、対象リクエストの設定情報を取得する。
要求電文の作成について要求電文の作成処理は SyncMessageConvertor に委譲する。
SyncMessageConvertorの取得方法は、MessageSender.getSyncMessageConvertor(MessageSenderSettings) メソッドのJavaDocを参照。
デフォルトでは、フレームワークが提供するSyncMessageConvertorをそのまま使用する。
メッセージの再送についてキューを使用した通信では、設定によりリトライ回数が指定されている場合、 タイムアウト発生時に指定された回数まで再送を行う。 HTTP通信では再送を行わない。 メッセージ送受信中にエラーが発生した場合、 SyncMessagingEventHook にエラー処理を委譲する。
SyncMessagingEventHookの設定方法はMessageSenderSettings.MessageSenderSettings(String) のJavaDocを参照。 |
Modifier and Type | Method and Description |
---|---|
SyncMessage |
HttpMessagingClient.sendSync(MessageSenderSettings settings,
SyncMessage requestMessage)
HTTPを使用したリアルタイム通信通信を行う。
|
Modifier and Type | Method and Description |
---|---|
protected void |
HttpMessagingClient.addCommonValue(nablarch.fw.messaging.realtime.http.client.HttpProtocolClient.HttpRequestMethodEnum httpMethod,
MessageSenderSettings settings,
SyncMessage requestMessage)
要求電文に、共通プロトコルヘッダ相当部分及びフレームワーク制御ヘッダ部で使用する要素を追加する。
|
protected nablarch.core.dataformat.SimpleDataConvertResult |
HttpMessagingClient.bodyStringToMap(java.lang.String uri,
nablarch.fw.messaging.realtime.http.client.HttpProtocolClient.HttpRequestMethodEnum httpMethod,
SyncMessage requestMessage,
HttpResult httpResult)
返信のボディ部分を解析し、応答電文に設定するデータを生成する。
|
protected java.util.Map |
HttpMessagingClient.headerToMap(SyncMessage requestMessage,
HttpResult httpResult)
返信のヘッダ部分を解析し、応答電文に設定するデータを生成する。
|
protected nablarch.core.dataformat.SimpleDataConvertResult |
HttpMessagingClient.mapToBodyString(java.lang.String uri,
nablarch.fw.messaging.realtime.http.client.HttpProtocolClient.HttpRequestMethodEnum httpMethod,
SyncMessage requestMessage)
HTTP通信のボディ部を生成する。
|
protected java.util.Map<java.util.List> |
HttpMessagingClient.mapToHeaderMap(SyncMessage requestMessage)
HTTPヘッダに含める内容を生成する。
|
protected java.util.Map |
HttpMessagingClient.mapToQueryMap(java.lang.String preUri,
nablarch.fw.messaging.realtime.http.client.HttpProtocolClient.HttpRequestMethodEnum httpMethod,
SyncMessage requestMessage)
クエリストリングを生成する。
|
protected java.lang.String |
HttpMessagingClient.mapToUriString(java.lang.String preUri,
nablarch.fw.messaging.realtime.http.client.HttpProtocolClient.HttpRequestMethodEnum httpMethod,
SyncMessage requestMessage)
URIを生成する。
|
SyncMessage |
HttpMessagingClient.sendSync(MessageSenderSettings settings,
SyncMessage requestMessage)
HTTPを使用したリアルタイム通信通信を行う。
|