Commit fb7333d4 by Nepxion

重构类结构

parent b222045b
...@@ -26,7 +26,7 @@ import com.nepxion.discovery.plugin.configcenter.constant.ConfigConstant; ...@@ -26,7 +26,7 @@ import com.nepxion.discovery.plugin.configcenter.constant.ConfigConstant;
import com.nepxion.discovery.plugin.configcenter.xml.Dom4JParser; import com.nepxion.discovery.plugin.configcenter.xml.Dom4JParser;
import com.nepxion.discovery.plugin.framework.entity.DiscoveryEntity; import com.nepxion.discovery.plugin.framework.entity.DiscoveryEntity;
import com.nepxion.discovery.plugin.framework.entity.DiscoveryServiceEntity; import com.nepxion.discovery.plugin.framework.entity.DiscoveryServiceEntity;
import com.nepxion.discovery.plugin.framework.entity.PluginEntity; import com.nepxion.discovery.plugin.framework.entity.RuleEntity;
import com.nepxion.discovery.plugin.framework.entity.RegisterEntity; import com.nepxion.discovery.plugin.framework.entity.RegisterEntity;
import com.nepxion.discovery.plugin.framework.entity.RegisterFilterType; import com.nepxion.discovery.plugin.framework.entity.RegisterFilterType;
import com.nepxion.discovery.plugin.framework.exception.PluginException; import com.nepxion.discovery.plugin.framework.exception.PluginException;
...@@ -35,7 +35,7 @@ public class ConfigParser extends Dom4JParser { ...@@ -35,7 +35,7 @@ public class ConfigParser extends Dom4JParser {
private static final Logger LOG = LoggerFactory.getLogger(ConfigParser.class); private static final Logger LOG = LoggerFactory.getLogger(ConfigParser.class);
@Autowired @Autowired
private PluginEntity pluginEntity; private RuleEntity ruleEntity;
@Autowired @Autowired
private ReentrantReadWriteLock reentrantReadWriteLock; private ReentrantReadWriteLock reentrantReadWriteLock;
...@@ -75,13 +75,13 @@ public class ConfigParser extends Dom4JParser { ...@@ -75,13 +75,13 @@ public class ConfigParser extends Dom4JParser {
try { try {
reentrantReadWriteLock.writeLock().lock(); reentrantReadWriteLock.writeLock().lock();
pluginEntity.setRegisterEntity(registerEntity); ruleEntity.setRegisterEntity(registerEntity);
pluginEntity.setDiscoveryEntity(discoveryEntity); ruleEntity.setDiscoveryEntity(discoveryEntity);
} finally { } finally {
reentrantReadWriteLock.writeLock().unlock(); reentrantReadWriteLock.writeLock().unlock();
} }
LOG.info("Plugin entity is {}", pluginEntity); LOG.info("Rule entity is {}", ruleEntity);
} }
@SuppressWarnings("rawtypes") @SuppressWarnings("rawtypes")
......
...@@ -15,15 +15,15 @@ import org.springframework.context.annotation.Bean; ...@@ -15,15 +15,15 @@ import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.Configuration;
import com.nepxion.discovery.plugin.framework.cache.PluginCache; import com.nepxion.discovery.plugin.framework.cache.PluginCache;
import com.nepxion.discovery.plugin.framework.entity.PluginEntity; import com.nepxion.discovery.plugin.framework.entity.RuleEntity;
import com.nepxion.discovery.plugin.framework.strategy.DiscoveryStrategy; import com.nepxion.discovery.plugin.framework.strategy.DiscoveryStrategy;
import com.nepxion.discovery.plugin.framework.strategy.RegisterStrategy; import com.nepxion.discovery.plugin.framework.strategy.RegisterStrategy;
@Configuration @Configuration
public class PluginAutoConfiguration { public class PluginAutoConfiguration {
@Bean @Bean
public PluginEntity pluginEntity() { public RuleEntity ruleEntity() {
return new PluginEntity(); return new RuleEntity();
} }
@Bean @Bean
......
...@@ -16,7 +16,7 @@ import org.apache.commons.lang3.builder.HashCodeBuilder; ...@@ -16,7 +16,7 @@ import org.apache.commons.lang3.builder.HashCodeBuilder;
import org.apache.commons.lang3.builder.ToStringBuilder; import org.apache.commons.lang3.builder.ToStringBuilder;
import org.apache.commons.lang3.builder.ToStringStyle; import org.apache.commons.lang3.builder.ToStringStyle;
public class PluginEntity implements Serializable { public class RuleEntity implements Serializable {
private static final long serialVersionUID = 7079024435084528751L; private static final long serialVersionUID = 7079024435084528751L;
private RegisterEntity registerEntity; private RegisterEntity registerEntity;
......
...@@ -26,11 +26,11 @@ import com.nepxion.discovery.plugin.framework.cache.PluginCache; ...@@ -26,11 +26,11 @@ import com.nepxion.discovery.plugin.framework.cache.PluginCache;
import com.nepxion.discovery.plugin.framework.constant.PluginConstant; import com.nepxion.discovery.plugin.framework.constant.PluginConstant;
import com.nepxion.discovery.plugin.framework.entity.DiscoveryEntity; import com.nepxion.discovery.plugin.framework.entity.DiscoveryEntity;
import com.nepxion.discovery.plugin.framework.entity.DiscoveryServiceEntity; import com.nepxion.discovery.plugin.framework.entity.DiscoveryServiceEntity;
import com.nepxion.discovery.plugin.framework.entity.PluginEntity; import com.nepxion.discovery.plugin.framework.entity.RuleEntity;
public class DiscoveryStrategy { public class DiscoveryStrategy {
@Autowired @Autowired
private PluginEntity pluginEntity; private RuleEntity pluginEntity;
@Autowired @Autowired
private PluginCache pluginCache; private PluginCache pluginCache;
......
...@@ -18,7 +18,7 @@ import org.slf4j.LoggerFactory; ...@@ -18,7 +18,7 @@ import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import com.nepxion.discovery.plugin.framework.constant.PluginConstant; import com.nepxion.discovery.plugin.framework.constant.PluginConstant;
import com.nepxion.discovery.plugin.framework.entity.PluginEntity; import com.nepxion.discovery.plugin.framework.entity.RuleEntity;
import com.nepxion.discovery.plugin.framework.entity.RegisterEntity; import com.nepxion.discovery.plugin.framework.entity.RegisterEntity;
import com.nepxion.discovery.plugin.framework.entity.RegisterFilterType; import com.nepxion.discovery.plugin.framework.entity.RegisterFilterType;
import com.nepxion.discovery.plugin.framework.exception.PluginException; import com.nepxion.discovery.plugin.framework.exception.PluginException;
...@@ -27,7 +27,7 @@ public class RegisterStrategy { ...@@ -27,7 +27,7 @@ public class RegisterStrategy {
private static final Logger LOG = LoggerFactory.getLogger(RegisterStrategy.class); private static final Logger LOG = LoggerFactory.getLogger(RegisterStrategy.class);
@Autowired @Autowired
private PluginEntity pluginEntity; private RuleEntity ruleEntity;
@Autowired @Autowired
private ReentrantReadWriteLock reentrantReadWriteLock; private ReentrantReadWriteLock reentrantReadWriteLock;
...@@ -43,7 +43,7 @@ public class RegisterStrategy { ...@@ -43,7 +43,7 @@ public class RegisterStrategy {
} }
private void applyIpAddressFilter(String serviceId, String ipAddress) { private void applyIpAddressFilter(String serviceId, String ipAddress) {
RegisterEntity registerEntity = pluginEntity.getRegisterEntity(); RegisterEntity registerEntity = ruleEntity.getRegisterEntity();
if (registerEntity == null) { if (registerEntity == null) {
return; return;
} }
......
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