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.