Browse Source

DEC-11501 【10.0.5】【集群】【Redis哨兵模式插件】配置新主节点名之后,集群节点异常

增加一个可以使多个配置缓存失效的 modify 接口
pull/32/head
Dylan.Liu 5 years ago
parent
commit
9b231dbb10
  1. 45
      src/main/java/com/fanruan/api/conf/ConfigurationKit.java

45
src/main/java/com/fanruan/api/conf/ConfigurationKit.java

@ -60,6 +60,26 @@ public class ConfigurationKit {
});
}
/**
* 在一个事务中修改配置
* 支持 configType, configTypes 缓存失效
*
* @param configType 配置类
* @param runner 执行器
* @param configTypes 配置类(所有的配置类都会缓存失效)
*/
public static void modify(Runner runner, Class<? extends Configuration> configType, Class<? extends Configuration>... configTypes) {
Configurations.modify(new WorkerFacade(configType, configTypes) {
@Override
public void run() {
if (runner != null) {
runner.run();
}
}
});
}
/**
* 在一个事务中修改配置
*
@ -81,4 +101,29 @@ public class ConfigurationKit {
}
Configurations.modify(facade);
}
/**
* 在一个事务中修改配置
* 支持 configType, configTypes 失效
*
* @param configType 配置类
* @param runner 执行器
* @param callBack 事务回调
* @param configTypes 配置类(所有的配置类都会缓存失效)
*/
public static void modify(Runner runner, WorkerCallBack callBack, Class<? extends Configuration> configType, Class<? extends Configuration>... configTypes) {
WorkerFacade facade = new WorkerFacade(configType, configTypes) {
@Override
public void run() {
if (runner != null) {
runner.run();
}
}
};
if (callBack != null) {
facade.addCallBack(callBack);
}
Configurations.modify(facade);
}
}

Loading…
Cancel
Save