public class DBAccessQueue
extends java.lang.Object
キュー処理用のDBアクセスクラス キューの受信と送信処理で、 データベースにアクセスして処理を行います。 実際のMQ,SQSとの通信そのものはfukurouで行います。
| 修飾子とタイプ | フィールドと説明 |
|---|---|
static java.lang.String |
FGKAN_END |
static java.lang.String |
FGKAN_ERROR |
static java.lang.String |
FGKAN_PROCESS |
| コンストラクタと説明 |
|---|
DBAccessQueue(java.lang.String systemid,
java.lang.String usrset,
java.lang.String prpupd,
java.lang.String dmnName)
コンストラクター
初期処理を行います。
|
| 修飾子とタイプ | メソッドと説明 |
|---|---|
java.lang.String |
generateSyoriNo()
処理番号生成
GE68_SEQUENCEからシーケンス番号を生成します。
|
void |
insertGE68(java.lang.String queueNm,
java.lang.String syno,
java.lang.String bizlogicId,
java.lang.String messageText)
GE68(キュー受信結果テーブル)登録
キュー受信結果テーブルに受信データを登録します。
|
java.lang.String[][] |
selectGE65()
GE65検索
GE65の処理対象リストを取得します。
|
java.lang.String[][] |
setlectGE67()
受信管理データ取得
受信管理テーブルから、キューIDとbizlogic名を取得します。
|
void |
updateGE66(java.lang.String ykno,
java.lang.String fgkan)
完了フラグの更新
完了フラグを指定された値に更新します。
|
void |
updateGE66Error(java.lang.String ykno,
java.lang.String errMsg)
エラー状態に更新
完了フラグをエラー状態に更新して、
エラー情報を格納します。
|
void |
updateGE68(java.lang.String syno,
java.lang.String fgkan)
GE68(キュー受信結果テーブル)更新
キュー受信結果テーブルを指定された完了状態に更新します。
|
void |
updateGE68Error(java.lang.String syoriNo,
java.lang.String errMsg)
GE68(キュー受信結果テーブル)エラー更新
キュー受信結果テーブルをエラー状態に更新します。
|
public static final java.lang.String FGKAN_PROCESS
public static final java.lang.String FGKAN_END
public static final java.lang.String FGKAN_ERROR
public DBAccessQueue(java.lang.String systemid,
java.lang.String usrset,
java.lang.String prpupd,
java.lang.String dmnName)
systemid - システムIDusrset - ユーザIDprpupd - プログラムIDdmnName - デーモン名public java.lang.String[][] selectGE65()
public void updateGE66Error(java.lang.String ykno,
java.lang.String errMsg)
ykno - 要求番号errMsg - エラーメッセージpublic void updateGE66(java.lang.String ykno,
java.lang.String fgkan)
ykno - 要求番号fgkan - 完了フラグpublic java.lang.String[][] setlectGE67()
public java.lang.String generateSyoriNo()
public void updateGE68(java.lang.String syno,
java.lang.String fgkan)
syno - 処理番号fgkan - 完了フラグpublic void insertGE68(java.lang.String queueNm,
java.lang.String syno,
java.lang.String bizlogicId,
java.lang.String messageText)
queueNm - キュー名syno - 処理NObizlogicId - ビズロジックIDmessageText - メッセージpublic void updateGE68Error(java.lang.String syoriNo,
java.lang.String errMsg)
syoriNo - 処理NOerrMsg - エラーメッセージWebアプリケーションフレームワーク openGionCopyright (c) 2009 The openGion Project.