Merge pull request #133 from CalebZYC/issue-132

优化refresherHandler实现类中实现重复的InitializingBean接口(#132)
pull/135/head
龙台 Long Tai 3 years ago committed by GitHub
commit 7f17e5b593
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

@ -13,6 +13,8 @@ import cn.hippo4j.core.starter.parser.ConfigParserHandler;
import cn.hippo4j.core.starter.support.GlobalCoreThreadPoolManage;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.boot.context.properties.bind.Bindable;
import org.springframework.boot.context.properties.bind.Binder;
import org.springframework.boot.context.properties.source.ConfigurationPropertySource;
@ -38,7 +40,7 @@ import static cn.hippo4j.core.starter.config.BootstrapCoreProperties.PREFIX;
*/
@Slf4j
@AllArgsConstructor
public abstract class AbstractCoreThreadPoolDynamicRefresh implements ThreadPoolDynamicRefresh {
public abstract class AbstractCoreThreadPoolDynamicRefresh implements ThreadPoolDynamicRefresh, InitializingBean {
private final ThreadPoolNotifyAlarmHandler threadPoolNotifyAlarmHandler;

@ -8,7 +8,6 @@ import com.ctrip.framework.apollo.ConfigFile;
import com.ctrip.framework.apollo.ConfigService;
import com.ctrip.framework.apollo.core.enums.ConfigFileFormat;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.beans.factory.annotation.Value;
/**
@ -17,7 +16,7 @@ import org.springframework.beans.factory.annotation.Value;
* @description:
*/
@Slf4j
public class ApolloRefresherHandler extends AbstractCoreThreadPoolDynamicRefresh implements InitializingBean {
public class ApolloRefresherHandler extends AbstractCoreThreadPoolDynamicRefresh {
private static final String APOLLO_PROPERTY = "${spring.dynamic.thread-pool.apollo.namespace:application}";

@ -6,7 +6,6 @@ import cn.hippo4j.core.starter.config.BootstrapCoreProperties;
import com.alibaba.cloud.nacos.NacosConfigManager;
import com.alibaba.nacos.api.config.listener.Listener;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.InitializingBean;
import java.util.Map;
import java.util.concurrent.Executor;
@ -18,7 +17,7 @@ import java.util.concurrent.Executor;
* @date 2022/2/26 11:21
*/
@Slf4j
public class NacosCloudRefresherHandler extends AbstractCoreThreadPoolDynamicRefresh implements InitializingBean {
public class NacosCloudRefresherHandler extends AbstractCoreThreadPoolDynamicRefresh {
private final NacosConfigManager nacosConfigManager;

@ -6,7 +6,6 @@ import cn.hippo4j.core.starter.config.BootstrapCoreProperties;
import com.alibaba.nacos.api.config.ConfigService;
import com.alibaba.nacos.api.config.listener.Listener;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.InitializingBean;
import java.util.Map;
import java.util.concurrent.Executor;
@ -18,7 +17,7 @@ import java.util.concurrent.Executor;
* @date 2022/2/26 00:10
*/
@Slf4j
public class NacosRefresherHandler extends AbstractCoreThreadPoolDynamicRefresh implements InitializingBean {
public class NacosRefresherHandler extends AbstractCoreThreadPoolDynamicRefresh {
private final ConfigService configService;

Loading…
Cancel
Save