public class org.apache.dubbo.registry.nacos.NacosServiceDiscovery extends org.apache.dubbo.registry.client.AbstractServiceDiscovery
{
private final org.apache.dubbo.common.logger.Logger logger;
private java.lang.String group;
private org.apache.dubbo.registry.nacos.NacosNamingServiceWrapper namingService;
private org.apache.dubbo.common.URL registryURL;
public void <init>()
{
java.lang.Class v;
org.apache.dubbo.registry.nacos.NacosServiceDiscovery v;
org.apache.dubbo.common.logger.Logger v;
v := @this: org.apache.dubbo.registry.nacos.NacosServiceDiscovery;
specialinvoke v.<org.apache.dubbo.registry.client.AbstractServiceDiscovery: void <init>()>();
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = staticinvoke <org.apache.dubbo.common.logger.LoggerFactory: org.apache.dubbo.common.logger.Logger getLogger(java.lang.Class)>(v);
v.<org.apache.dubbo.registry.nacos.NacosServiceDiscovery: org.apache.dubbo.common.logger.Logger logger> = v;
return;
}
public void initialize(org.apache.dubbo.common.URL) throws java.lang.Exception
{
org.apache.dubbo.common.URL v;
org.apache.dubbo.registry.nacos.NacosNamingServiceWrapper v;
java.lang.String v;
org.apache.dubbo.registry.nacos.NacosServiceDiscovery v;
v := @this: org.apache.dubbo.registry.nacos.NacosServiceDiscovery;
v := @parameter: org.apache.dubbo.common.URL;
v = staticinvoke <org.apache.dubbo.registry.nacos.util.NacosNamingServiceUtils: org.apache.dubbo.registry.nacos.NacosNamingServiceWrapper createNamingService(org.apache.dubbo.common.URL)>(v);
v.<org.apache.dubbo.registry.nacos.NacosServiceDiscovery: org.apache.dubbo.registry.nacos.NacosNamingServiceWrapper namingService> = v;
v = staticinvoke <org.apache.dubbo.registry.nacos.util.NacosNamingServiceUtils: java.lang.String getGroup(org.apache.dubbo.common.URL)>(v);
v.<org.apache.dubbo.registry.nacos.NacosServiceDiscovery: java.lang.String group> = v;
v.<org.apache.dubbo.registry.nacos.NacosServiceDiscovery: org.apache.dubbo.common.URL registryURL> = v;
return;
}
public void destroy()
{
org.apache.dubbo.registry.nacos.NacosServiceDiscovery v;
v := @this: org.apache.dubbo.registry.nacos.NacosServiceDiscovery;
v.<org.apache.dubbo.registry.nacos.NacosServiceDiscovery: org.apache.dubbo.registry.nacos.NacosNamingServiceWrapper namingService> = null;
return;
}
public void doRegister(org.apache.dubbo.registry.client.ServiceInstance)
{
org.apache.dubbo.common.function.ThrowableConsumer v;
org.apache.dubbo.registry.client.ServiceInstance v;
org.apache.dubbo.registry.nacos.NacosNamingServiceWrapper v;
org.apache.dubbo.registry.nacos.NacosServiceDiscovery v;
v := @this: org.apache.dubbo.registry.nacos.NacosServiceDiscovery;
v := @parameter: org.apache.dubbo.registry.client.ServiceInstance;
v = v.<org.apache.dubbo.registry.nacos.NacosServiceDiscovery: org.apache.dubbo.registry.nacos.NacosNamingServiceWrapper namingService>;
v = staticinvoke <org.apache.dubbo.registry.nacos.NacosServiceDiscovery$lambda_doRegister_0__16: org.apache.dubbo.common.function.ThrowableConsumer bootstrap$(org.apache.dubbo.registry.nacos.NacosServiceDiscovery,org.apache.dubbo.registry.client.ServiceInstance)>(v, v);
staticinvoke <org.apache.dubbo.common.function.ThrowableConsumer: void execute(java.lang.Object,org.apache.dubbo.common.function.ThrowableConsumer)>(v, v);
return;
}
public void doUpdate(org.apache.dubbo.registry.client.ServiceInstance)
{
org.apache.dubbo.registry.client.ServiceInstance v, v;
org.apache.dubbo.registry.nacos.NacosServiceDiscovery v;
v := @this: org.apache.dubbo.registry.nacos.NacosServiceDiscovery;
v := @parameter: org.apache.dubbo.registry.client.ServiceInstance;
v = v.<org.apache.dubbo.registry.nacos.NacosServiceDiscovery: org.apache.dubbo.registry.client.ServiceInstance serviceInstance>;
if v != null goto label;
virtualinvoke v.<org.apache.dubbo.registry.nacos.NacosServiceDiscovery: void register(org.apache.dubbo.registry.client.ServiceInstance)>(v);
goto label;
label:
virtualinvoke v.<org.apache.dubbo.registry.nacos.NacosServiceDiscovery: void unregister(org.apache.dubbo.registry.client.ServiceInstance)>(v);
virtualinvoke v.<org.apache.dubbo.registry.nacos.NacosServiceDiscovery: void register(org.apache.dubbo.registry.client.ServiceInstance)>(v);
label:
return;
}
public void unregister(org.apache.dubbo.registry.client.ServiceInstance) throws java.lang.RuntimeException
{
org.apache.dubbo.common.function.ThrowableConsumer v;
org.apache.dubbo.registry.client.ServiceInstance v;
org.apache.dubbo.registry.nacos.NacosNamingServiceWrapper v;
org.apache.dubbo.registry.nacos.NacosServiceDiscovery v;
v := @this: org.apache.dubbo.registry.nacos.NacosServiceDiscovery;
v := @parameter: org.apache.dubbo.registry.client.ServiceInstance;
v = v.<org.apache.dubbo.registry.nacos.NacosServiceDiscovery: org.apache.dubbo.registry.nacos.NacosNamingServiceWrapper namingService>;
v = staticinvoke <org.apache.dubbo.registry.nacos.NacosServiceDiscovery$lambda_unregister_1__17: org.apache.dubbo.common.function.ThrowableConsumer bootstrap$(org.apache.dubbo.registry.nacos.NacosServiceDiscovery,org.apache.dubbo.registry.client.ServiceInstance)>(v, v);
staticinvoke <org.apache.dubbo.common.function.ThrowableConsumer: void execute(java.lang.Object,org.apache.dubbo.common.function.ThrowableConsumer)>(v, v);
return;
}
public java.util.Set getServices()
{
org.apache.dubbo.registry.nacos.NacosNamingServiceWrapper v;
java.lang.Object v;
org.apache.dubbo.common.function.ThrowableFunction v;
org.apache.dubbo.registry.nacos.NacosServiceDiscovery v;
v := @this: org.apache.dubbo.registry.nacos.NacosServiceDiscovery;
v = v.<org.apache.dubbo.registry.nacos.NacosServiceDiscovery: org.apache.dubbo.registry.nacos.NacosNamingServiceWrapper namingService>;
v = staticinvoke <org.apache.dubbo.registry.nacos.NacosServiceDiscovery$lambda_getServices_2__18: org.apache.dubbo.common.function.ThrowableFunction bootstrap$(org.apache.dubbo.registry.nacos.NacosServiceDiscovery)>(v);
v = staticinvoke <org.apache.dubbo.common.function.ThrowableFunction: java.lang.Object execute(java.lang.Object,org.apache.dubbo.common.function.ThrowableFunction)>(v, v);
return v;
}
public java.util.List getInstances(java.lang.String) throws java.lang.NullPointerException
{
org.apache.dubbo.registry.nacos.NacosNamingServiceWrapper v;
java.lang.Object v;
java.lang.String v;
org.apache.dubbo.common.function.ThrowableFunction v;
org.apache.dubbo.registry.nacos.NacosServiceDiscovery v;
v := @this: org.apache.dubbo.registry.nacos.NacosServiceDiscovery;
v := @parameter: java.lang.String;
v = v.<org.apache.dubbo.registry.nacos.NacosServiceDiscovery: org.apache.dubbo.registry.nacos.NacosNamingServiceWrapper namingService>;
v = staticinvoke <org.apache.dubbo.registry.nacos.NacosServiceDiscovery$lambda_getInstances_3__19: org.apache.dubbo.common.function.ThrowableFunction bootstrap$(java.lang.String)>(v);
v = staticinvoke <org.apache.dubbo.common.function.ThrowableFunction: java.lang.Object execute(java.lang.Object,org.apache.dubbo.common.function.ThrowableFunction)>(v, v);
return v;
}
public void addServiceInstancesChangedListener(org.apache.dubbo.registry.client.event.listener.ServiceInstancesChangedListener) throws java.lang.NullPointerException, java.lang.IllegalArgumentException
{
org.apache.dubbo.common.function.ThrowableConsumer v;
org.apache.dubbo.registry.client.event.listener.ServiceInstancesChangedListener v;
org.apache.dubbo.registry.nacos.NacosNamingServiceWrapper v;
org.apache.dubbo.registry.nacos.NacosServiceDiscovery v;
v := @this: org.apache.dubbo.registry.nacos.NacosServiceDiscovery;
v := @parameter: org.apache.dubbo.registry.client.event.listener.ServiceInstancesChangedListener;
v = v.<org.apache.dubbo.registry.nacos.NacosServiceDiscovery: org.apache.dubbo.registry.nacos.NacosNamingServiceWrapper namingService>;
v = staticinvoke <org.apache.dubbo.registry.nacos.NacosServiceDiscovery$lambda_addServiceInstancesChangedListener_6__20: org.apache.dubbo.common.function.ThrowableConsumer bootstrap$(org.apache.dubbo.registry.nacos.NacosServiceDiscovery,org.apache.dubbo.registry.client.event.listener.ServiceInstancesChangedListener)>(v, v);
staticinvoke <org.apache.dubbo.common.function.ThrowableConsumer: void execute(java.lang.Object,org.apache.dubbo.common.function.ThrowableConsumer)>(v, v);
return;
}
public org.apache.dubbo.common.URL getUrl()
{
org.apache.dubbo.common.URL v;
org.apache.dubbo.registry.nacos.NacosServiceDiscovery v;
v := @this: org.apache.dubbo.registry.nacos.NacosServiceDiscovery;
v = v.<org.apache.dubbo.registry.nacos.NacosServiceDiscovery: org.apache.dubbo.common.URL registryURL>;
return v;
}
private void handleEvent(com.alibaba.nacos.api.naming.listener.NamingEvent, org.apache.dubbo.registry.client.event.listener.ServiceInstancesChangedListener)
{
java.util.function.Function v;
java.util.List v;
java.util.stream.Stream v, v;
org.apache.dubbo.registry.client.event.listener.ServiceInstancesChangedListener v;
java.lang.Object v;
java.lang.String v;
java.util.stream.Collector v;
com.alibaba.nacos.api.naming.listener.NamingEvent v;
org.apache.dubbo.registry.nacos.NacosServiceDiscovery v;
v := @this: org.apache.dubbo.registry.nacos.NacosServiceDiscovery;
v := @parameter: com.alibaba.nacos.api.naming.listener.NamingEvent;
v := @parameter: org.apache.dubbo.registry.client.event.listener.ServiceInstancesChangedListener;
v = virtualinvoke v.<com.alibaba.nacos.api.naming.listener.NamingEvent: java.lang.String getServiceName()>();
v = virtualinvoke v.<com.alibaba.nacos.api.naming.listener.NamingEvent: java.util.List getInstances()>();
v = interfaceinvoke v.<java.util.List: java.util.stream.Stream stream()>();
v = staticinvoke <org.apache.dubbo.registry.nacos.NacosServiceDiscovery$toServiceInstance__21: java.util.function.Function bootstrap$()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream map(java.util.function.Function)>(v);
v = staticinvoke <java.util.stream.Collectors: java.util.stream.Collector toList()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.lang.Object collect(java.util.stream.Collector)>(v);
virtualinvoke v.<org.apache.dubbo.registry.nacos.NacosServiceDiscovery: void dispatchServiceInstancesChangedEvent(java.lang.String,java.util.List)>(v, v);
return;
}
private void appendPreservedParam(com.alibaba.nacos.api.naming.pojo.Instance)
{
org.apache.dubbo.common.URL v;
com.alibaba.nacos.api.naming.pojo.Instance v;
java.util.Map v, v;
org.apache.dubbo.registry.nacos.NacosServiceDiscovery v;
v := @this: org.apache.dubbo.registry.nacos.NacosServiceDiscovery;
v := @parameter: com.alibaba.nacos.api.naming.pojo.Instance;
v = virtualinvoke v.<org.apache.dubbo.registry.nacos.NacosServiceDiscovery: org.apache.dubbo.common.URL getUrl()>();
v = staticinvoke <org.apache.dubbo.registry.nacos.util.NacosNamingServiceUtils: java.util.Map getNacosPreservedParam(org.apache.dubbo.common.URL)>(v);
v = virtualinvoke v.<com.alibaba.nacos.api.naming.pojo.Instance: java.util.Map getMetadata()>();
interfaceinvoke v.<java.util.Map: void putAll(java.util.Map)>(v);
return;
}
}