Package com.networknt.zookeeper

Class ZooKeeperRegistry

java.lang.Object

com.networknt.registry.support.FailbackRegistry

com.networknt.registry.support.command.CommandFailbackRegistry

com.networknt.zookeeper.ZooKeeperRegistry

All Implemented Interfaces:

DiscoveryService, Registry, RegistryService

public class ZooKeeperRegistry
extends CommandFailbackRegistry

The ZooKeeper Registry implementation.

Field Summary

Fields

Modifier and Type	Field	Description
protected String	registryClassName

Constructor Summary

Constructors

Constructor	Description
ZooKeeperRegistry(URL url, ZooKeeperClient client)

Method Summary

Modifier and Type	Method	Description
void	available(URL arg0)
protected List<URL>	discoverService(URL url)
protected void	doAvailable(URL url)
protected void	doRegister(URL url)
protected void	doUnavailable(URL url)
protected void	doUnregister(URL url)
Collection<URL>	getRegisteredServiceUrls()
ConcurrentHashMap<URL,ConcurrentHashMap<ServiceListener,org.I0Itec.zkclient.IZkChildListener>>	getServiceListeners()
URL	getUrl()
protected void	notify(URL arg0, NotifyListener arg1, List<URL> arg2)
protected void	subscribeService(URL url, ServiceListener serviceListener)
void	unavailable(URL arg0)
protected void	unsubscribeService(URL url, ServiceListener serviceListener)

Methods inherited from class com.networknt.registry.support.command.CommandFailbackRegistry

doDiscover, doSubscribe, doUnsubscribe, getCommandManagerMap

Methods inherited from class com.networknt.registry.support.FailbackRegistry

discover, register, subscribe, unregister, unsubscribe

Methods inherited from class java.lang.Object

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

Field Detail

registryClassName

protected String registryClassName

Constructor Detail

ZooKeeperRegistry

public ZooKeeperRegistry(URL url,
                         ZooKeeperClient client)

Method Detail

getServiceListeners

public ConcurrentHashMap<URL,ConcurrentHashMap<ServiceListener,org.I0Itec.zkclient.IZkChildListener>> getServiceListeners()

subscribeService

protected void subscribeService(URL url,
                                ServiceListener serviceListener)

Specified by:

subscribeService in class CommandFailbackRegistry

unsubscribeService

protected void unsubscribeService(URL url,
                                  ServiceListener serviceListener)

Specified by:

unsubscribeService in class CommandFailbackRegistry

discoverService

protected List<URL> discoverService(URL url)

Specified by:

discoverService in class CommandFailbackRegistry

doRegister

protected void doRegister(URL url)

doUnregister

protected void doUnregister(URL url)

doAvailable

protected void doAvailable(URL url)

doUnavailable

protected void doUnavailable(URL url)

getUrl

public URL getUrl()

Specified by:

getUrl in interface Registry

getRegisteredServiceUrls

public Collection<URL> getRegisteredServiceUrls()

Specified by:

getRegisteredServiceUrls in interface RegistryService

available

public void available(URL arg0)

Specified by:

available in interface RegistryService

unavailable

public void unavailable(URL arg0)

Specified by:

unavailable in interface RegistryService

notify

protected void notify(URL arg0,
                      NotifyListener arg1,
                      List<URL> arg2)