|
...
|
...
|
@@ -48,7 +48,7 @@ public class IMFNoDelaySender extends Thread{ |
|
|
|
|
|
|
|
while(true) {
|
|
|
|
//初始化读取
|
|
|
|
logger.info("job start，发送线程开始:");
|
|
|
|
logger.info("job start，发送线程开始["+Thread.currentThread().getName()+"]");
|
|
|
|
int lastFID = Utils.readFIDIndex(this.indexFileName);
|
|
|
|
int maxFID = this.dao.getMaxFID(sqlMax);
|
|
|
|
logger.info("lastROW=" + lastFID + " maxCount=" + maxFID);
|
|
...
|
...
|
@@ -135,8 +135,8 @@ public class IMFNoDelaySender extends Thread{ |
|
|
|
}
|
|
|
|
}else {
|
|
|
|
try {
|
|
|
|
Thread.sleep(10000L);
|
|
|
|
logger.info("发送线程休眠");
|
|
|
|
Thread.sleep(100000L);
|
|
|
|
logger.info("发送线程》》》"+Thread.currentThread().getName()+"休眠");
|
|
|
|
} catch (InterruptedException var3) {
|
|
|
|
var3.printStackTrace();
|
|
|
|
}
|
...
|
...
|
|
