gtsoft/gtsoft-snail-job-server
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects 1 Releases Wiki Activity

feat(sj_1.0.0): 去除EnableSnailJob的group默认配置，采用yml配置

Browse Source
This commit is contained in:
opensnail 2024-05-24 16:27:50 +08:00
parent f48316e9fb
commit 01127611fa
2 changed files with 1 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
snail-job-client-starter/src/main/java/com/aizuda/snailjob/client/starter/EnableSnailJob.java
View File

@ -33,13 +33,6 @@ import java.lang.annotation.*;
@Import(SnailJobClientsRegistrar.class) @Import(SnailJobClientsRegistrar.class)
public @interface EnableSnailJob { public @interface EnableSnailJob {
/**
* 表示该重试数据属于哪个系统并且全局唯一
*
* @return
*/
String group();
/** /**
* 控制多个Aop的执行顺序, * 控制多个Aop的执行顺序,
* 需要注意的是这里顺序要比事务的Aop要提前 * 需要注意的是这里顺序要比事务的Aop要提前

2
snail-job-client-starter/src/main/java/com/aizuda/snailjob/client/starter/SnailJobClientsRegistrar.java
View File

@ -23,7 +23,6 @@ public class SnailJobClientsRegistrar implements ImportBeanDefinitionRegistrar,
public void registerBeanDefinitions(AnnotationMetadata importingClassMetadata, BeanDefinitionRegistry registry) { public void registerBeanDefinitions(AnnotationMetadata importingClassMetadata, BeanDefinitionRegistry registry) {
Map<String, Object> attrs = importingClassMetadata.getAnnotationAttributes(EnableSnailJob.class.getName()); Map<String, Object> attrs = importingClassMetadata.getAnnotationAttributes(EnableSnailJob.class.getName());
Map<String, Object> systemEnvironment = standardEnvironment.getSystemProperties(); Map<String, Object> systemEnvironment = standardEnvironment.getSystemProperties();
systemEnvironment.put("snail-job.group", attrs.get("group"));
systemEnvironment.put("snail-job.aop.order", attrs.get("order")); systemEnvironment.put("snail-job.aop.order", attrs.get("order"));
} }
@ -32,6 +31,7 @@ public class SnailJobClientsRegistrar implements ImportBeanDefinitionRegistrar,
StandardEnvironment standardEnvironment = (StandardEnvironment) environment; StandardEnvironment standardEnvironment = (StandardEnvironment) environment;
this.standardEnvironment = standardEnvironment; this.standardEnvironment = standardEnvironment;
Map<String, Object> systemEnvironment = standardEnvironment.getSystemProperties(); Map<String, Object> systemEnvironment = standardEnvironment.getSystemProperties();
// 添加了 EnableSnailJob 默认就是开启，无需手动配置
systemEnvironment.put("snail-job.enabled", true); systemEnvironment.put("snail-job.enabled", true);
} }
} }