Clean Code

This commit is contained in:
xuxueli 2017-08-30 22:50:41 +08:00
parent 1970f7f3b8
commit 03979398f1
3 changed files with 3 additions and 3 deletions

View File

@ -78,7 +78,7 @@ public final class XxlJobDynamicScheduler implements ApplicationContextAware {
// valid // valid
Assert.notNull(scheduler, "quartz scheduler is null"); Assert.notNull(scheduler, "quartz scheduler is null");
logger.info(">>>>>>>>> init quartz scheduler success.[{}]", scheduler); logger.info(">>>>>>>>> init xxl-job admin success.");
} }
public void destroy(){ public void destroy(){

View File

@ -133,7 +133,7 @@ public class XxlJobExecutor implements ApplicationContextAware {
// ---------------------- job handler repository ---------------------- // ---------------------- job handler repository ----------------------
private static ConcurrentHashMap<String, IJobHandler> jobHandlerRepository = new ConcurrentHashMap<String, IJobHandler>(); private static ConcurrentHashMap<String, IJobHandler> jobHandlerRepository = new ConcurrentHashMap<String, IJobHandler>();
public static IJobHandler registJobHandler(String name, IJobHandler jobHandler){ public static IJobHandler registJobHandler(String name, IJobHandler jobHandler){
logger.info("xxl-job register jobhandler success, name:{}, jobHandler:{}", name, jobHandler); logger.info(">>>>>>>>>>> xxl-job register jobhandler success, name:{}, jobHandler:{}", name, jobHandler);
return jobHandlerRepository.put(name, jobHandler); return jobHandlerRepository.put(name, jobHandler);
} }
public static IJobHandler loadJobHandler(String name){ public static IJobHandler loadJobHandler(String name){

View File

@ -39,7 +39,7 @@ public class XxlJobConfig {
@Bean(initMethod = "start", destroyMethod = "destroy") @Bean(initMethod = "start", destroyMethod = "destroy")
public XxlJobExecutor xxlJobExecutor() { public XxlJobExecutor xxlJobExecutor() {
logger.error("------------ xxlJobExecutor -----------"); logger.info(">>>>>>>>>>> xxl-job config init.");
XxlJobExecutor xxlJobExecutor = new XxlJobExecutor(); XxlJobExecutor xxlJobExecutor = new XxlJobExecutor();
xxlJobExecutor.setIp(ip); xxlJobExecutor.setIp(ip);
xxlJobExecutor.setPort(port); xxlJobExecutor.setPort(port);