作者 朱兆平

无延迟发送

@@ -51,7 +51,7 @@ public class IMFNoDelaySender extends Thread{ @@ -51,7 +51,7 @@ public class IMFNoDelaySender extends Thread{
51 logger.info("job start:"); 51 logger.info("job start:");
52 int lastFID = Utils.readFIDIndex(this.indexFileName); 52 int lastFID = Utils.readFIDIndex(this.indexFileName);
53 int maxFID = this.dao.getMaxFID(sqlMax); 53 int maxFID = this.dao.getMaxFID(sqlMax);
54 - logger.info("lastFID=" + lastFID + " maxFID=" + maxFID); 54 + logger.info("lastROW=" + lastFID + " maxCount=" + maxFID);
55 int is_ok = 0; 55 int is_ok = 0;
56 56
57 if (maxFID > lastFID) { 57 if (maxFID > lastFID) {