修复由于FileCacheQueueScheduler中fileCursor 文件再次打开时没有初始化抛出NullPointerException的错误

pull/53/head
jon 11 years ago
parent 090827f124
commit a722f9bb66

@ -126,7 +126,7 @@ public class FileCacheQueueScheduler implements Scheduler {
private void readCursorFile() throws IOException { private void readCursorFile() throws IOException {
BufferedReader fileCursorReader = null; BufferedReader fileCursorReader = null;
try { try {
new BufferedReader(new FileReader(getFileName(fileCursor))); fileCursorReader = new BufferedReader(new FileReader(getFileName(fileCursor)));
String line; String line;
//read the last number //read the last number
while ((line = fileCursorReader.readLine()) != null) { while ((line = fileCursorReader.readLine()) != null) {

Loading…
Cancel
Save