|
|
|
|
@ -3,18 +3,12 @@ package com.xxl.job.admin.scheduler.alarm;
|
|
|
|
|
import com.xxl.job.admin.model.XxlJobInfo;
|
|
|
|
|
import com.xxl.job.admin.model.XxlJobLog;
|
|
|
|
|
import com.xxl.tool.core.CollectionTool;
|
|
|
|
|
import com.xxl.tool.core.MapTool;
|
|
|
|
|
import org.slf4j.Logger;
|
|
|
|
|
import org.slf4j.LoggerFactory;
|
|
|
|
|
import org.springframework.beans.BeansException;
|
|
|
|
|
import org.springframework.beans.factory.InitializingBean;
|
|
|
|
|
import org.springframework.context.ApplicationContext;
|
|
|
|
|
import org.springframework.context.ApplicationContextAware;
|
|
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
|
|
import org.springframework.stereotype.Component;
|
|
|
|
|
|
|
|
|
|
import java.util.ArrayList;
|
|
|
|
|
import java.util.List;
|
|
|
|
|
import java.util.Map;
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* xxl-job alarmer
|
|
|
|
|
@ -22,25 +16,12 @@ import java.util.Map;
|
|
|
|
|
* @author xuxueli 17/7/13.
|
|
|
|
|
*/
|
|
|
|
|
@Component
|
|
|
|
|
public class JobAlarmer implements ApplicationContextAware, InitializingBean {
|
|
|
|
|
public class JobAlarmer {
|
|
|
|
|
private static final Logger logger = LoggerFactory.getLogger(JobAlarmer.class);
|
|
|
|
|
|
|
|
|
|
private ApplicationContext applicationContext;
|
|
|
|
|
@Autowired
|
|
|
|
|
private List<JobAlarm> jobAlarmList;
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|
public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
|
|
|
|
|
this.applicationContext = applicationContext;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|
public void afterPropertiesSet() throws Exception {
|
|
|
|
|
Map<String, JobAlarm> serviceBeanMap = applicationContext.getBeansOfType(JobAlarm.class);
|
|
|
|
|
if (MapTool.isNotEmpty(serviceBeanMap)) {
|
|
|
|
|
jobAlarmList = new ArrayList<>(serviceBeanMap.values());
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* job alarm
|
|
|
|
|
*/
|
|
|
|
|
@ -65,4 +46,22 @@ public class JobAlarmer implements ApplicationContextAware, InitializingBean {
|
|
|
|
|
return result;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
|
// implements SmartInitializingSingleton
|
|
|
|
|
// implements ApplicationContextAware, InitializingBean
|
|
|
|
|
private ApplicationContext applicationContext;
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|
public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
|
|
|
|
|
this.applicationContext = applicationContext;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|
public void afterPropertiesSet() throws Exception {
|
|
|
|
|
Map<String, JobAlarm> serviceBeanMap = applicationContext.getBeansOfType(JobAlarm.class);
|
|
|
|
|
if (MapTool.isNotEmpty(serviceBeanMap)) {
|
|
|
|
|
jobAlarmList = new ArrayList<>(serviceBeanMap.values());
|
|
|
|
|
}
|
|
|
|
|
}*/
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|