public class MessageReader extends java.lang.Object implements DataReader<ReceivedMessage>
MessageReadError
)を送出する。DataReader
DataReader.NoMoreRecord
コンストラクタと説明 |
---|
MessageReader() |
修飾子とタイプ | メソッドと説明 |
---|---|
void |
close(ExecutionContext ctx)
このリーダのクローズフラグを立て新規電文の受信を停止する。
|
boolean |
hasNext(ExecutionContext ctx)
次に読み込むデータが存在するかどうかを返却する。
|
ReceivedMessage |
read(ExecutionContext ctx)
受信電文を読み込む。
|
MessageReader |
setFormatFileDirName(java.lang.String dirName)
受信電文のフォーマット定義ファイルが配置されているディレクトリの
論理名を指定する。
|
MessageReader |
setFormatFileName(java.lang.String fileName)
受信電文のフォーマット定義ファイル名を設定する。
|
MessageReader |
setReadTimeout(long timeout)
受信キューが空の場合に待機する最大時間を設定する。
|
MessageReader |
setReceiveQueueName(java.lang.String queueName)
このリーダが監視する受信キューの論理名を設定する。
|
public ReceivedMessage read(ExecutionContext ctx)
MessagingContext
オブジェクトを使用して受信キューから電文を取得し返却する。null
を返却する。read
インタフェース内 DataReader<ReceivedMessage>
ctx
- 実行コンテキストjava.lang.IllegalStateException
- 受信キューの論理名がnull
の場合java.lang.RuntimeException
- 実行時例外が発生した場合java.lang.Error
- エラーが発生した場合MessageReadError
- 受信電文オブジェクトの設定中に
実行時例外またはエラーが発生した場合public boolean hasNext(ExecutionContext ctx)
hasNext
インタフェース内 DataReader<ReceivedMessage>
ctx
- 実行コンテキストtrue
public void close(ExecutionContext ctx)
close
インタフェース内 DataReader<ReceivedMessage>
ctx
- 実行コンテキストpublic MessageReader setReceiveQueueName(java.lang.String queueName)
queueName
- 受信キューの論理名public MessageReader setReadTimeout(long timeout)
timeout
- 受信タイムアウト(単位:ミリ秒)public MessageReader setFormatFileName(java.lang.String fileName)
fileName
- フォーマット定義ファイル名public MessageReader setFormatFileDirName(java.lang.String dirName)
dirName
- フォーマット定義ファイル配置ディレクトリの論理名