クラス DBAccessQueue
java.lang.Object
org.opengion.hayabusa.queue.DBAccessQueue
キュー処理用のDBアクセスクラス
キューの受信と送信処理で、
データベースにアクセスして処理を行います。
実際のMQ,SQSとの通信そのものはfukurouで行います。
- 変更履歴:
- 5.10.15.2 (2019/09/20) 新規作成
- 機能分類
- メッセージ連携
- 導入されたバージョン:
- JDK7
-
フィールドの概要
フィールド -
コンストラクタの概要
コンストラクタコンストラクタ説明DBAccessQueue
(String systemid, String usrset, String prpupd, String dmnName) コンストラクター 初期処理を行います。 -
メソッドの概要
修飾子とタイプメソッド説明処理番号生成 GE68_SEQUENCEからシーケンス番号を生成します。void
insertGE68
(String queueNm, String syno, String bizlogicId, String messageText) GE68(キュー受信結果テーブル)登録 キュー受信結果テーブルに受信データを登録します。String[][]
GE65検索 GE65の処理対象リストを取得します。String[][]
受信管理データ取得 受信管理テーブルから、キューIDとbizlogic名を取得します。void
updateGE66
(String ykno, String fgkan) 完了フラグの更新 完了フラグを指定された値に更新します。void
updateGE66Error
(String ykno, String errMsg) エラー状態に更新 完了フラグをエラー状態に更新して、 エラー情報を格納します。void
updateGE68
(String syno, String fgkan) GE68(キュー受信結果テーブル)更新 キュー受信結果テーブルを指定された完了状態に更新します。void
updateGE68Error
(String syoriNo, String errMsg) GE68(キュー受信結果テーブル)エラー更新 キュー受信結果テーブルをエラー状態に更新します。
-
フィールド詳細
-
コンストラクタの詳細
-
DBAccessQueue
コンストラクター 初期処理を行います。- パラメータ:
systemid
- システムIDusrset
- ユーザIDprpupd
- プログラムIDdmnName
- デーモン名
-
-
メソッドの詳細
-
selectGE65
GE65検索 GE65の処理対象リストを取得します。- 戻り値:
- 処理対象リスト
-
updateGE66Error
エラー状態に更新 完了フラグをエラー状態に更新して、 エラー情報を格納します。- パラメータ:
ykno
- 要求番号errMsg
- エラーメッセージ
-
updateGE66
完了フラグの更新 完了フラグを指定された値に更新します。- パラメータ:
ykno
- 要求番号fgkan
- 完了フラグ
-
setlectGE67
受信管理データ取得 受信管理テーブルから、キューIDとbizlogic名を取得します。- 戻り値:
- 受信管理リスト
-
generateSyoriNo
処理番号生成 GE68_SEQUENCEからシーケンス番号を生成します。- 戻り値:
- 処理番号
- 変更履歴:
- 7.0.6.4 (2019/11/29) TransactionRealのclose漏れ対応
-
updateGE68
GE68(キュー受信結果テーブル)更新 キュー受信結果テーブルを指定された完了状態に更新します。- パラメータ:
syno
- 処理番号fgkan
- 完了フラグ
-
insertGE68
GE68(キュー受信結果テーブル)登録 キュー受信結果テーブルに受信データを登録します。- パラメータ:
queueNm
- キュー名syno
- 処理NObizlogicId
- ビズロジックIDmessageText
- メッセージ
-
updateGE68Error
GE68(キュー受信結果テーブル)エラー更新 キュー受信結果テーブルをエラー状態に更新します。- パラメータ:
syoriNo
- 処理NOerrMsg
- エラーメッセージ
-