Commit c1a7d538 by Nepxion

Nacos配置支持客户自定义

parent f2c18352
...@@ -31,7 +31,7 @@ public class NacosAutoConfiguration { ...@@ -31,7 +31,7 @@ public class NacosAutoConfiguration {
@Bean @Bean
@ConditionalOnMissingBean @ConditionalOnMissingBean
public ConfigService configService() throws NacosException { public ConfigService nacosConfigService() throws NacosException {
Properties properties = new Properties(); Properties properties = new Properties();
String url = environment.getProperty(NacosConstant.URL); String url = environment.getProperty(NacosConstant.URL);
......
...@@ -13,8 +13,8 @@ import com.alibaba.nacos.api.PropertyKeyConst; ...@@ -13,8 +13,8 @@ import com.alibaba.nacos.api.PropertyKeyConst;
public class NacosConstant extends PropertyKeyConst { public class NacosConstant extends PropertyKeyConst {
public static final String URL = "nacos.url"; public static final String URL = "nacos.url";
public static final String TIMEOUT = "nacos.timout"; public static final String NAMESPACE = "nacos.discovery.namespace";
public static final String NAMESPACE = "nacos.namespace"; public static final String TIMEOUT = "nacos.discovery.timout";
public static final long DEFAULT_TIMEOUT = 30000; public static final long DEFAULT_TIMEOUT = 30000;
} }
\ No newline at end of file
...@@ -21,7 +21,7 @@ import com.nepxion.discovery.common.nacos.constant.NacosConstant; ...@@ -21,7 +21,7 @@ import com.nepxion.discovery.common.nacos.constant.NacosConstant;
public class NacosOperation { public class NacosOperation {
@Autowired @Autowired
private ConfigService configService; private ConfigService nacosConfigService;
@Autowired @Autowired
private Environment environment; private Environment environment;
...@@ -29,15 +29,15 @@ public class NacosOperation { ...@@ -29,15 +29,15 @@ public class NacosOperation {
public String getConfig(String group, String serviceId) throws NacosException { public String getConfig(String group, String serviceId) throws NacosException {
long timeout = environment.getProperty(NacosConstant.TIMEOUT, Long.class, NacosConstant.DEFAULT_TIMEOUT); long timeout = environment.getProperty(NacosConstant.TIMEOUT, Long.class, NacosConstant.DEFAULT_TIMEOUT);
return configService.getConfig(serviceId, group, timeout); return nacosConfigService.getConfig(serviceId, group, timeout);
} }
public boolean removeConfig(String group, String serviceId) throws NacosException { public boolean removeConfig(String group, String serviceId) throws NacosException {
return configService.removeConfig(serviceId, group); return nacosConfigService.removeConfig(serviceId, group);
} }
public boolean publishConfig(String group, String serviceId, String config) throws NacosException { public boolean publishConfig(String group, String serviceId, String config) throws NacosException {
return configService.publishConfig(serviceId, group, config); return nacosConfigService.publishConfig(serviceId, group, config);
} }
public Listener subscribeConfig(String group, String serviceId, Executor executor, NacosSubscribeCallback subscribeCallback) throws NacosException { public Listener subscribeConfig(String group, String serviceId, Executor executor, NacosSubscribeCallback subscribeCallback) throws NacosException {
...@@ -53,12 +53,12 @@ public class NacosOperation { ...@@ -53,12 +53,12 @@ public class NacosOperation {
} }
}; };
configService.addListener(serviceId, group, configListener); nacosConfigService.addListener(serviceId, group, configListener);
return configListener; return configListener;
} }
public void unsubscribeConfig(String group, String serviceId, Listener configListener) { public void unsubscribeConfig(String group, String serviceId, Listener configListener) {
configService.removeListener(serviceId, group, configListener); nacosConfigService.removeListener(serviceId, group, configListener);
} }
} }
\ 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