update document
This commit is contained in:
parent
b09520b83e
commit
a73ecb631f
|
@ -44,6 +44,7 @@ public class JobScheduleHelper {
|
||||||
logger.error(e.getMessage(), e);
|
logger.error(e.getMessage(), e);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
logger.info(">>>>>>>>> init xxl-job admin scheduler running.");
|
||||||
|
|
||||||
while (!toStop) {
|
while (!toStop) {
|
||||||
|
|
||||||
|
@ -111,7 +112,7 @@ public class JobScheduleHelper {
|
||||||
}
|
}
|
||||||
ringItemData.add(jobInfo.getId());
|
ringItemData.add(jobInfo.getId());
|
||||||
|
|
||||||
logger.info(">>>>>>>>>>> xxl-job, push time-ring : " + ringSecond + " = " + Arrays.asList(ringItemData) );
|
logger.debug(">>>>>>>>>>> xxl-job, push time-ring : " + ringSecond + " = " + Arrays.asList(ringItemData) );
|
||||||
}
|
}
|
||||||
|
|
||||||
// 3、更新trigger信息
|
// 3、更新trigger信息
|
||||||
|
@ -190,7 +191,7 @@ public class JobScheduleHelper {
|
||||||
lastSecond = nowSecond;
|
lastSecond = nowSecond;
|
||||||
|
|
||||||
|
|
||||||
logger.info(">>>>>>>>>>> xxl-job, time-ring beat : " + nowSecond + " = " + Arrays.asList(ringItemData) );
|
logger.debug(">>>>>>>>>>> xxl-job, time-ring beat : " + nowSecond + " = " + Arrays.asList(ringItemData) );
|
||||||
if (ringItemData!=null && ringItemData.size()>0) {
|
if (ringItemData!=null && ringItemData.size()>0) {
|
||||||
// do trigger
|
// do trigger
|
||||||
for (int jobId: ringItemData) {
|
for (int jobId: ringItemData) {
|
||||||
|
|
Loading…
Reference in New Issue