🐛 Fixing a bug. close #3648 pigx-xxl-job-admin 项目启动错误日志
This commit is contained in:
1 parent
db8ff631ce
commit
9fbc295947
3 files changed
+32
-3
No files matched your search
+26
@@ -0,0 +1,26 @@
|
||||
package com.xxl.job.admin.config;
|
||||
|
||||
import com.xxl.job.admin.core.conf.XxlJobAdminConfig;
|
||||
import lombok.RequiredArgsConstructor;
|
||||
import lombok.SneakyThrows;
|
||||
import org.springframework.boot.web.context.WebServerInitializedEvent;
|
||||
import org.springframework.context.annotation.Configuration;
|
||||
import org.springframework.context.event.EventListener;
|
||||
|
||||
/**
|
||||
* @author lengleng
|
||||
* @date 2022/2/28
|
||||
*/
|
||||
@RequiredArgsConstructor
|
||||
@Configuration(proxyBeanMethods = false)
|
||||
public class XxlJobInitConfiguration {
|
||||
|
||||
private final XxlJobAdminConfig xxlJobAdminConfig;
|
||||
|
||||
@SneakyThrows
|
||||
@EventListener({ WebServerInitializedEvent.class })
|
||||
public void init() {
|
||||
xxlJobAdminConfig.getXxlJobScheduler().init();
|
||||
}
|
||||
|
||||
}
|
||||
+4
-1
@@ -37,7 +37,7 @@ public class XxlJobAdminConfig implements InitializingBean, DisposableBean {
|
||||
adminConfig = this;
|
||||
|
||||
xxlJobScheduler = new XxlJobScheduler();
|
||||
xxlJobScheduler.init();
|
||||
// xxlJobScheduler.init();
|
||||
}
|
||||
|
||||
@Override
|
||||
@@ -160,4 +160,7 @@ public class XxlJobAdminConfig implements InitializingBean, DisposableBean {
|
||||
return jobAlarmer;
|
||||
}
|
||||
|
||||
public XxlJobScheduler getXxlJobScheduler() {
|
||||
return xxlJobScheduler;
|
||||
}
|
||||
}
|
||||
+2
-2
@@ -99,7 +99,7 @@ public class JobLogReportHelper {
|
||||
}
|
||||
catch (Exception e) {
|
||||
if (!toStop) {
|
||||
logger.error(">>>>>>>>>>> xxl-job, job log report thread error");
|
||||
logger.error(">>>>>>>>>>> xxl-job, job log report thread error:{}", e);
|
||||
}
|
||||
}
|
||||
|
||||
@@ -137,7 +137,7 @@ public class JobLogReportHelper {
|
||||
}
|
||||
catch (Exception e) {
|
||||
if (!toStop) {
|
||||
logger.error(e.getMessage());
|
||||
logger.error(e.getMessage(), e);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
Reference in new issue
Block a user