|
@@ -48,7 +48,7 @@ public class ExecutorRegistryThread extends Thread {
|
48
|
48
|
ReturnT<String> registryResult = adminBiz.registry(registryParam);
|
49
|
49
|
if (registryResult!=null && ReturnT.SUCCESS_CODE == registryResult.getCode()) {
|
50
|
50
|
registryResult = ReturnT.SUCCESS;
|
51
|
|
- logger.info(">>>>>>>>>>> xxl-job registry success, registryParam:{}, registryResult:{}", new Object[]{registryParam, registryResult});
|
|
51
|
+ logger.debug(">>>>>>>>>>> xxl-job registry success, registryParam:{}, registryResult:{}", new Object[]{registryParam, registryResult});
|
52
|
52
|
break;
|
53
|
53
|
} else {
|
54
|
54
|
logger.info(">>>>>>>>>>> xxl-job registry fail, registryParam:{}, registryResult:{}", new Object[]{registryParam, registryResult});
|
|
@@ -66,7 +66,9 @@ public class ExecutorRegistryThread extends Thread {
|
66
|
66
|
}
|
67
|
67
|
|
68
|
68
|
try {
|
69
|
|
- TimeUnit.SECONDS.sleep(RegistryConfig.BEAT_TIMEOUT);
|
|
69
|
+ if (!toStop) {
|
|
70
|
+ TimeUnit.SECONDS.sleep(RegistryConfig.BEAT_TIMEOUT);
|
|
71
|
+ }
|
70
|
72
|
} catch (InterruptedException e) {
|
71
|
73
|
if (!toStop) {
|
72
|
74
|
logger.warn(">>>>>>>>>>> xxl-job, executor registry thread interrupted, error msg:{}", e.getMessage());
|