Package org.apache.dubbo.registry.client

Class ReflectionBasedServiceDiscovery

java.lang.Object

org.apache.dubbo.registry.client.AbstractServiceDiscovery

org.apache.dubbo.registry.client.ReflectionBasedServiceDiscovery

All Implemented Interfaces:

Comparable<Prioritized>, Prioritized, ServiceDiscovery, RegistryService

public class ReflectionBasedServiceDiscovery
extends AbstractServiceDiscovery

Field Summary

Fields

Modifier and Type	Field	Description
ConcurrentMap<String,MetadataService>	metadataServiceProxies

Fields inherited from interface org.apache.dubbo.common.lang.Prioritized

COMPARATOR, MAX_PRIORITY, MIN_PRIORITY, NORMAL_PRIORITY

Constructor Summary

Constructors

Constructor	Description
ReflectionBasedServiceDiscovery(ApplicationModel applicationModel, URL registryURL)

Method Summary

Modifier and Type	Method	Description
void	doDestroy()
void	doInitialize(URL registryURL)
void	doRegister(ServiceInstance serviceInstance)
void	doUnregister(ServiceInstance serviceInstance)
final void	fillServiceInstance(DefaultServiceInstance serviceInstance)
final ConcurrentHashMap<String,List<ServiceInstance>>	getCachedServiceInstances()	Deprecated.
List<ServiceInstance>	getInstances(String serviceName)
Set<String>	getServices()	Gets all service names
final void	notifyListener(String serviceName, ServiceInstancesChangedListener listener, List<ServiceInstance> instances)

Methods inherited from class org.apache.dubbo.registry.client.AbstractServiceDiscovery

destroy, getLocalInstance, getLocalMetadata, getLocalMetadata, getRemoteMetadata, getRemoteMetadata, getUrl, isDestroy, lookup, register, register, subscribe, unregister, unregister, unsubscribe, update

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.dubbo.common.lang.Prioritized

compareTo, getPriority

Methods inherited from interface org.apache.dubbo.registry.client.ServiceDiscovery

addServiceInstancesChangedListener, createListener, getDelay, isAvailable, removeServiceInstancesChangedListener, toString

Field Details

metadataServiceProxies

public ConcurrentMap<String,MetadataService> metadataServiceProxies

Constructor Details

ReflectionBasedServiceDiscovery

public ReflectionBasedServiceDiscovery(ApplicationModel applicationModel,
 URL registryURL)

Method Details

doInitialize

public void doInitialize(URL registryURL)

doDestroy

public void doDestroy()
               throws Exception

Throws:

Exception

doRegister

public void doRegister(ServiceInstance serviceInstance)
                throws RuntimeException

Throws:

RuntimeException

doUnregister

public void doUnregister(ServiceInstance serviceInstance)
                  throws RuntimeException

Throws:

RuntimeException

fillServiceInstance

public final void fillServiceInstance(DefaultServiceInstance serviceInstance)

notifyListener

public final void notifyListener(String serviceName,
 ServiceInstancesChangedListener listener,
 List<ServiceInstance> instances)

getServices

public Set<String> getServices()

Description copied from interface: ServiceDiscovery

Gets all service names

Returns:

non-null read-only Set

getInstances

public List<ServiceInstance> getInstances(String serviceName)
                                   throws NullPointerException

Throws:

NullPointerException

getCachedServiceInstances

@Deprecated
public final ConcurrentHashMap<String,List<ServiceInstance>> getCachedServiceInstances()

Deprecated.

UT used only