diff --git a/snail-job-client-starter/src/main/java/com/aizuda/snailjob/client/starter/EnableSnailJob.java b/snail-job-client-starter/src/main/java/com/aizuda/snailjob/client/starter/EnableSnailJob.java index fac4231b..ba598071 100644 --- a/snail-job-client-starter/src/main/java/com/aizuda/snailjob/client/starter/EnableSnailJob.java +++ b/snail-job-client-starter/src/main/java/com/aizuda/snailjob/client/starter/EnableSnailJob.java @@ -33,13 +33,6 @@ import java.lang.annotation.*; @Import(SnailJobClientsRegistrar.class) public @interface EnableSnailJob { - /** - * 表示该重试数据属于哪个系统并且全局唯一 - * - * @return - */ - String group(); - /** * 控制多个Aop的执行顺序, * 需要注意的是这里顺序要比事务的Aop要提前 diff --git a/snail-job-client-starter/src/main/java/com/aizuda/snailjob/client/starter/SnailJobClientsRegistrar.java b/snail-job-client-starter/src/main/java/com/aizuda/snailjob/client/starter/SnailJobClientsRegistrar.java index ccf2a379..b6bd703c 100644 --- a/snail-job-client-starter/src/main/java/com/aizuda/snailjob/client/starter/SnailJobClientsRegistrar.java +++ b/snail-job-client-starter/src/main/java/com/aizuda/snailjob/client/starter/SnailJobClientsRegistrar.java @@ -23,7 +23,6 @@ public class SnailJobClientsRegistrar implements ImportBeanDefinitionRegistrar, public void registerBeanDefinitions(AnnotationMetadata importingClassMetadata, BeanDefinitionRegistry registry) { Map attrs = importingClassMetadata.getAnnotationAttributes(EnableSnailJob.class.getName()); Map systemEnvironment = standardEnvironment.getSystemProperties(); - systemEnvironment.put("snail-job.group", attrs.get("group")); systemEnvironment.put("snail-job.aop.order", attrs.get("order")); } @@ -32,6 +31,7 @@ public class SnailJobClientsRegistrar implements ImportBeanDefinitionRegistrar, StandardEnvironment standardEnvironment = (StandardEnvironment) environment; this.standardEnvironment = standardEnvironment; Map systemEnvironment = standardEnvironment.getSystemProperties(); + // 添加了 EnableSnailJob 默认就是开启,无需手动配置 systemEnvironment.put("snail-job.enabled", true); } }