Package org.apache.dubbo.registry.client.event.listener

Class ServiceInstancesChangedListener

java.lang.Object

org.apache.dubbo.registry.client.event.listener.ServiceInstancesChangedListener

public class ServiceInstancesChangedListener
extends Object

TODO, refactor to move revision-metadata mapping to ServiceDiscovery. Instances should have already been mapped with metadata when reached here.

The operations of ServiceInstancesChangedListener should be synchronized.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ServiceInstancesChangedListener.NotifyListenerWithKey
static class	ServiceInstancesChangedListener.ProtocolServiceKeyWithUrls

Constructor Summary

Constructors

Constructor	Description
ServiceInstancesChangedListener(Set<String> serviceNames, ServiceDiscovery serviceDiscovery)

Method Summary

Modifier and Type	Method	Description
void	addListenerAndNotify(URL url, NotifyListener listener)
void	destroy()	Since this listener is shared among interfaces, destroy this listener only when all interface listener are unsubscribed
boolean	equals(Object o)
Map<String,List<ServiceInstance>>	getAllInstances()
final Set<String>	getServiceNames()	Get the correlative service name
int	hashCode()
boolean	hasListeners()
boolean	isDestroyed()
void	onEvent(ServiceInstancesChangedEvent event)	On the service instances change event
void	removeListener(String serviceKey, NotifyListener notifyListener)

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ServiceInstancesChangedListener

public ServiceInstancesChangedListener(Set<String> serviceNames,
 ServiceDiscovery serviceDiscovery)

Method Details

onEvent

public void onEvent(ServiceInstancesChangedEvent event)

On the service instances change event

Parameters:

event - ServiceInstancesChangedEvent

addListenerAndNotify

public void addListenerAndNotify(URL url,
 NotifyListener listener)

removeListener

public void removeListener(String serviceKey,
 NotifyListener notifyListener)

hasListeners

public boolean hasListeners()

getServiceNames

public final Set<String> getServiceNames()

Get the correlative service name

Returns:

the correlative service name

getAllInstances

public Map<String,List<ServiceInstance>> getAllInstances()

destroy

public void destroy()

Since this listener is shared among interfaces, destroy this listener only when all interface listener are unsubscribed

isDestroyed

public boolean isDestroyed()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object