study/Spring-Cloud-Alibaba
1
0
Fork 0
mirror of https://gitee.com/mirrors/Spring-Cloud-Alibaba.git synced 2021-06-26 13:25:11 +08:00
Code Issues Releases Wiki Activity

Polish alibaba/spring-cloud-alibaba#1363 : Sync spring-cloud-starter-dubbo module

Browse Source
This commit is contained in:
mercyblitz 2020-04-14 13:36:57 +08:00
parent d11f2a0608
commit 27ed9ff1c9
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
spring-cloud-alibaba-starters/spring-cloud-starter-dubbo/src/main/java/com/alibaba/cloud/dubbo/registry/AbstractSpringCloudRegistry.java
View File

@ -98,10 +98,10 @@ public abstract class AbstractSpringCloudRegistry extends FailbackRegistry {
private final ConfigurableApplicationContext applicationContext; private final ConfigurableApplicationContext applicationContext;
public AbstractSpringCloudRegistry(URL url, DiscoveryClient discoveryClient, public AbstractSpringCloudRegistry(URL url, DiscoveryClient discoveryClient,
DubboServiceMetadataRepository dubboServiceMetadataRepository, DubboServiceMetadataRepository dubboServiceMetadataRepository,
DubboMetadataServiceProxy dubboMetadataConfigServiceProxy, DubboMetadataServiceProxy dubboMetadataConfigServiceProxy,
JSONUtils jsonUtils, DubboGenericServiceFactory dubboGenericServiceFactory, JSONUtils jsonUtils, DubboGenericServiceFactory dubboGenericServiceFactory,
ConfigurableApplicationContext applicationContext) { ConfigurableApplicationContext applicationContext) {
super(url); super(url);
this.servicesLookupInterval = url this.servicesLookupInterval = url
.getParameter(SERVICES_LOOKUP_INTERVAL_PARAM_NAME, 60L); .getParameter(SERVICES_LOOKUP_INTERVAL_PARAM_NAME, 60L);
@ -190,7 +190,7 @@ public abstract class AbstractSpringCloudRegistry extends FailbackRegistry {
* @param listener {@link NotifyListener} * @param listener {@link NotifyListener}
*/ */
private void registerServiceInstancesChangedEventListener(URL url, private void registerServiceInstancesChangedEventListener(URL url,
NotifyListener listener) { NotifyListener listener) {
String listenerId = generateId(url); String listenerId = generateId(url);
if (registerListeners.add(listenerId)) { if (registerListeners.add(listenerId)) {
applicationContext.addApplicationListener( applicationContext.addApplicationListener(
@ -217,8 +217,8 @@ public abstract class AbstractSpringCloudRegistry extends FailbackRegistry {
} }
protected void subscribeDubboServiceURL(URL url, NotifyListener listener, protected void subscribeDubboServiceURL(URL url, NotifyListener listener,
String serviceName, String serviceName,
Function<String, Collection<ServiceInstance>> serviceInstancesFunction) { Function<String, Collection<ServiceInstance>> serviceInstancesFunction) {
if (logger.isInfoEnabled()) { if (logger.isInfoEnabled()) {
logger.info( logger.info(
@ -355,7 +355,7 @@ public abstract class AbstractSpringCloudRegistry extends FailbackRegistry {
} }
private List<URL> getExportedURLs(DubboMetadataService dubboMetadataService, private List<URL> getExportedURLs(DubboMetadataService dubboMetadataService,
URL url) { URL url) {
String serviceInterface = url.getServiceInterface(); String serviceInterface = url.getServiceInterface();
String group = url.getParameter(GROUP_KEY); String group = url.getParameter(GROUP_KEY);
String version = url.getParameter(VERSION_KEY); String version = url.getParameter(VERSION_KEY);