Package org.apache.dubbo.registry.integration

Class DynamicDirectory<T>

java.lang.Object

org.apache.dubbo.rpc.cluster.directory.AbstractDirectory<T>

org.apache.dubbo.registry.integration.DynamicDirectory<T>

All Implemented Interfaces:

Node, NotifyListener, Directory<T>

Direct Known Subclasses:

RegistryDirectory, ServiceDiscoveryRegistryDirectory

public abstract class DynamicDirectory<T>
extends AbstractDirectory<T>
implements NotifyListener

DynamicDirectory

Constructor Summary

Constructors

Constructor	Description
DynamicDirectory(Class<T> serviceType, URL url)

Method Summary

Modifier and Type	Method	Description
void	addServiceListener(ServiceInstancesChangedListener instanceListener)
void	buildRouterChain(URL url)
void	destroy()
void	discordAddresses()
List<org.apache.dubbo.rpc.Invoker<T>>	doList(SingleRouterChain<T> singleRouterChain, BitList<org.apache.dubbo.rpc.Invoker<T>> invokers, org.apache.dubbo.rpc.Invocation invocation)
List<org.apache.dubbo.rpc.Invoker<T>>	getAllInvokers()
URL	getConsumerUrl()	The currently effective consumer url
Class<T>	getInterface()
URL	getOriginalConsumerUrl()	The original consumer url
URL	getRegisteredConsumerUrl()	The url registered to registry or metadata center
Registry	getRegistry()
ServiceInstancesChangedListener	getServiceListener()
URL	getSubscribeUrl()	The url used to subscribe from registry
boolean	isAvailable()
boolean	isNotificationReceived()
boolean	isShouldRegister()
void	setInvokersChangedListener(InvokersChangedListener listener)
void	setProtocol(org.apache.dubbo.rpc.Protocol protocol)
void	setRegisteredConsumerUrl(URL url)
void	setRegistry(Registry registry)
void	setSubscribeUrl(URL subscribeUrl)
void	subscribe(URL url)
void	unSubscribe(URL url)

Methods inherited from class org.apache.dubbo.rpc.cluster.directory.AbstractDirectory

addDisabledInvoker, addInvalidateInvoker, checkConnectivity, getCheckConnectivityPermit, getConnectivityCheckFuture, getDisabledInvokers, getInvokers, getInvokersToReconnect, getRouterChain, getUrl, getValidInvokers, isDestroyed, list, recoverDisabledInvoker, refreshInvoker, setConsumerUrl, setRouterChain, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.dubbo.rpc.cluster.Directory

isEmpty, isServiceDiscovery

Methods inherited from interface org.apache.dubbo.registry.NotifyListener

notify

Constructor Details

DynamicDirectory

public DynamicDirectory(Class<T> serviceType,
 URL url)

Method Details

addServiceListener

public void addServiceListener(ServiceInstancesChangedListener instanceListener)

Specified by:

addServiceListener in interface NotifyListener

getServiceListener

public ServiceInstancesChangedListener getServiceListener()

Specified by:

getServiceListener in interface NotifyListener

setProtocol

public void setProtocol(org.apache.dubbo.rpc.Protocol protocol)

setRegistry

public void setRegistry(Registry registry)

getRegistry

public Registry getRegistry()

isShouldRegister

public boolean isShouldRegister()

subscribe

public void subscribe(URL url)

unSubscribe

public void unSubscribe(URL url)

doList

public List<org.apache.dubbo.rpc.Invoker<T>> doList(SingleRouterChain<T> singleRouterChain,
 BitList<org.apache.dubbo.rpc.Invoker<T>> invokers,
 org.apache.dubbo.rpc.Invocation invocation)

getInterface

public Class<T> getInterface()

Specified by:

getInterface in interface Directory<T>

getAllInvokers

public List<org.apache.dubbo.rpc.Invoker<T>> getAllInvokers()

Specified by:

getAllInvokers in interface Directory<T>

getConsumerUrl

public URL getConsumerUrl()

The currently effective consumer url

Specified by:

getConsumerUrl in interface Directory<T>

Specified by:

getConsumerUrl in interface NotifyListener

Overrides:

getConsumerUrl in class AbstractDirectory<T>

Returns:

URL

getOriginalConsumerUrl

public URL getOriginalConsumerUrl()

The original consumer url

Returns:

URL

getRegisteredConsumerUrl

public URL getRegisteredConsumerUrl()

The url registered to registry or metadata center

Returns:

URL

getSubscribeUrl

public URL getSubscribeUrl()

The url used to subscribe from registry

Returns:

URL

setSubscribeUrl

public void setSubscribeUrl(URL subscribeUrl)

setRegisteredConsumerUrl

public void setRegisteredConsumerUrl(URL url)

buildRouterChain

public void buildRouterChain(URL url)

isAvailable

public boolean isAvailable()

Specified by:

isAvailable in interface Node

destroy

public void destroy()

Specified by:

destroy in interface Node

Overrides:

destroy in class AbstractDirectory<T>

discordAddresses

public void discordAddresses()

Specified by:

discordAddresses in interface Directory<T>

Overrides:

discordAddresses in class AbstractDirectory<T>

setInvokersChangedListener

public void setInvokersChangedListener(InvokersChangedListener listener)

isNotificationReceived

public boolean isNotificationReceived()

Specified by:

isNotificationReceived in interface Directory<T>