Commit 5b397658 by Nepxion

抽象ConfigContextClosedHandler

parent c8c07963
...@@ -14,7 +14,6 @@ import org.springframework.context.annotation.Configuration; ...@@ -14,7 +14,6 @@ import org.springframework.context.annotation.Configuration;
import com.nepxion.discovery.plugin.configcenter.adapter.ConfigAdapter; import com.nepxion.discovery.plugin.configcenter.adapter.ConfigAdapter;
import com.nepxion.discovery.plugin.configcenter.nacos.adapter.NacosConfigAdapter; import com.nepxion.discovery.plugin.configcenter.nacos.adapter.NacosConfigAdapter;
import com.nepxion.discovery.plugin.configcenter.nacos.context.NacosConfigContextClosedHandler;
@Configuration @Configuration
public class NacosConfigAutoConfiguration { public class NacosConfigAutoConfiguration {
...@@ -22,9 +21,4 @@ public class NacosConfigAutoConfiguration { ...@@ -22,9 +21,4 @@ public class NacosConfigAutoConfiguration {
public ConfigAdapter configAdapter() { public ConfigAdapter configAdapter() {
return new NacosConfigAdapter(); return new NacosConfigAdapter();
} }
@Bean
public NacosConfigContextClosedHandler configContextClosedHandler() {
return new NacosConfigContextClosedHandler();
}
} }
\ No newline at end of file
...@@ -21,7 +21,6 @@ import org.springframework.data.redis.listener.adapter.MessageListenerAdapter; ...@@ -21,7 +21,6 @@ import org.springframework.data.redis.listener.adapter.MessageListenerAdapter;
import com.nepxion.discovery.plugin.configcenter.adapter.ConfigAdapter; import com.nepxion.discovery.plugin.configcenter.adapter.ConfigAdapter;
import com.nepxion.discovery.plugin.configcenter.redis.adapter.RedisConfigAdapter; import com.nepxion.discovery.plugin.configcenter.redis.adapter.RedisConfigAdapter;
import com.nepxion.discovery.plugin.configcenter.redis.context.RedisConfigContextClosedHandler;
import com.nepxion.discovery.plugin.framework.adapter.PluginAdapter; import com.nepxion.discovery.plugin.framework.adapter.PluginAdapter;
import com.nepxion.discovery.plugin.framework.context.PluginContextAware; import com.nepxion.discovery.plugin.framework.context.PluginContextAware;
...@@ -77,9 +76,4 @@ public class RedisConfigAutoConfiguration { ...@@ -77,9 +76,4 @@ public class RedisConfigAutoConfiguration {
public ConfigAdapter configAdapter() { public ConfigAdapter configAdapter() {
return new RedisConfigAdapter(); return new RedisConfigAdapter();
} }
@Bean
public RedisConfigContextClosedHandler configContextClosedHandler() {
return new RedisConfigContextClosedHandler();
}
} }
\ No newline at end of file
package com.nepxion.discovery.plugin.configcenter.redis.context;
/**
* <p>Title: Nepxion Discovery</p>
* <p>Description: Nepxion Discovery</p>
* <p>Copyright: Copyright (c) 2017-2050</p>
* <p>Company: Nepxion</p>
* @author Haojun Ren
* @version 1.0
*/
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationListener;
import org.springframework.context.event.ContextClosedEvent;
import com.nepxion.discovery.plugin.configcenter.redis.adapter.RedisConfigAdapter;
public class RedisConfigContextClosedHandler implements ApplicationListener<ContextClosedEvent> {
@Autowired
private RedisConfigAdapter redisConfigAdapter;
@Override
public void onApplicationEvent(ContextClosedEvent event) {
redisConfigAdapter.close();
}
}
\ No newline at end of file
...@@ -16,6 +16,7 @@ import org.springframework.context.annotation.Configuration; ...@@ -16,6 +16,7 @@ import org.springframework.context.annotation.Configuration;
import com.nepxion.discovery.common.constant.DiscoveryConstant; import com.nepxion.discovery.common.constant.DiscoveryConstant;
import com.nepxion.discovery.common.exception.DiscoveryException; import com.nepxion.discovery.common.exception.DiscoveryException;
import com.nepxion.discovery.plugin.configcenter.context.ConfigContextClosedHandler;
import com.nepxion.discovery.plugin.configcenter.initializer.ConfigInitializer; import com.nepxion.discovery.plugin.configcenter.initializer.ConfigInitializer;
import com.nepxion.discovery.plugin.configcenter.loader.LocalConfigLoader; import com.nepxion.discovery.plugin.configcenter.loader.LocalConfigLoader;
import com.nepxion.discovery.plugin.configcenter.parser.json.JsonConfigParser; import com.nepxion.discovery.plugin.configcenter.parser.json.JsonConfigParser;
...@@ -54,4 +55,9 @@ public class ConfigAutoConfiguration { ...@@ -54,4 +55,9 @@ public class ConfigAutoConfiguration {
public ConfigInitializer configInitializer() { public ConfigInitializer configInitializer() {
return new ConfigInitializer(); return new ConfigInitializer();
} }
@Bean
public ConfigContextClosedHandler configContextClosedHandler() {
return new ConfigContextClosedHandler();
}
} }
\ No newline at end of file
package com.nepxion.discovery.plugin.configcenter.nacos.context; package com.nepxion.discovery.plugin.configcenter.context;
/** /**
* <p>Title: Nepxion Discovery</p> * <p>Title: Nepxion Discovery</p>
...@@ -13,14 +13,16 @@ import org.springframework.beans.factory.annotation.Autowired; ...@@ -13,14 +13,16 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationListener; import org.springframework.context.ApplicationListener;
import org.springframework.context.event.ContextClosedEvent; import org.springframework.context.event.ContextClosedEvent;
import com.nepxion.discovery.plugin.configcenter.nacos.adapter.NacosConfigAdapter; import com.nepxion.discovery.plugin.configcenter.loader.RemoteConfigLoader;
public class NacosConfigContextClosedHandler implements ApplicationListener<ContextClosedEvent> { public class ConfigContextClosedHandler implements ApplicationListener<ContextClosedEvent> {
@Autowired @Autowired(required = false)
private NacosConfigAdapter nacosConfigAdapter; private RemoteConfigLoader remoteConfigLoader;
@Override @Override
public void onApplicationEvent(ContextClosedEvent event) { public void onApplicationEvent(ContextClosedEvent event) {
nacosConfigAdapter.close(); if (remoteConfigLoader != null) {
remoteConfigLoader.close();
}
} }
} }
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment