| | |
| | | * @author xuxueli 2018-10-28 00:18:17 |
| | | */ |
| | | |
| | | public class XxlJobScheduler { |
| | | public class XxlJobScheduler { |
| | | private static final Logger logger = LoggerFactory.getLogger(XxlJobScheduler.class); |
| | | |
| | | |
| | |
| | | logger.info(">>>>>>>>> init xxl-job admin success."); |
| | | } |
| | | |
| | | |
| | | |
| | | public void destroy() throws Exception { |
| | | |
| | | // stop-schedule |
| | |
| | | |
| | | // ---------------------- I18n ---------------------- |
| | | |
| | | private void initI18n(){ |
| | | for (ExecutorBlockStrategyEnum item:ExecutorBlockStrategyEnum.values()) { |
| | | private void initI18n() { |
| | | for (ExecutorBlockStrategyEnum item : ExecutorBlockStrategyEnum.values()) { |
| | | item.setTitle(I18nUtil.getString("jobconf_block_".concat(item.name()))); |
| | | } |
| | | } |
| | | |
| | | // ---------------------- executor-client ---------------------- |
| | | private static ConcurrentMap<String, ExecutorBiz> executorBizRepository = new ConcurrentHashMap<String, ExecutorBiz>(); |
| | | |
| | | public static ExecutorBiz getExecutorBiz(String address) throws Exception { |
| | | // valid |
| | | if (address==null || address.trim().length()==0) { |
| | | if (address == null || address.trim().length() == 0) { |
| | | return null; |
| | | } |
| | | |