Package org.apache.dubbo.registry.integration

Class RegistryProtocol

java.lang.Object

org.apache.dubbo.registry.integration.RegistryProtocol

All Implemented Interfaces:

ScopeModelAware, org.apache.dubbo.rpc.Protocol

Direct Known Subclasses:

InterfaceCompatibleRegistryProtocol

public class RegistryProtocol
extends Object
implements org.apache.dubbo.rpc.Protocol, ScopeModelAware

TODO, replace RegistryProtocol completely in the future.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	RegistryProtocol.InvokerDelegate<T>

Field Summary

Fields

Modifier and Type	Field	Description
static final String[]	DEFAULT_REGISTER_CONSUMER_KEYS
static final String[]	DEFAULT_REGISTER_PROVIDER_KEYS

Constructor Summary

Constructors

Constructor	Description
RegistryProtocol()

Method Summary

Modifier and Type	Method	Description
void	destroy()
<T> org.apache.dubbo.rpc.Exporter<T>	export(org.apache.dubbo.rpc.Invoker<T> originInvoker)
int	getDefaultPort()
<T> ClusterInvoker<T>	getInvoker(Cluster cluster, Registry registry, Class<T> type, URL url)
Map<URL,Set<NotifyListener>>	getOverrideListeners()
List<org.apache.dubbo.rpc.ProtocolServer>	getServers()
<T> ClusterInvoker<T>	getServiceDiscoveryInvoker(Cluster cluster, Registry registry, Class<T> type, URL url)
<T> void	reExport(org.apache.dubbo.rpc.Exporter<T> exporter, URL newInvokerUrl)
<T> void	reExport(org.apache.dubbo.rpc.Invoker<T> originInvoker, URL newInvokerUrl)	Reexport the invoker of the modified url
<T> org.apache.dubbo.rpc.Invoker<T>	refer(Class<T> type, URL url)
<T> void	reRefer(ClusterInvoker<?> invoker, URL newSubscribeUrl)
void	setFrameworkModel(FrameworkModel frameworkModel)
void	setProtocol(org.apache.dubbo.rpc.Protocol protocol)
void	setProxyFactory(org.apache.dubbo.rpc.ProxyFactory proxyFactory)
static URL	toSubscribeUrl(URL url)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.dubbo.rpc.model.ScopeModelAware

setApplicationModel, setModuleModel, setScopeModel

Field Details

DEFAULT_REGISTER_PROVIDER_KEYS

public static final String[] DEFAULT_REGISTER_PROVIDER_KEYS

DEFAULT_REGISTER_CONSUMER_KEYS

public static final String[] DEFAULT_REGISTER_CONSUMER_KEYS

Constructor Details

RegistryProtocol

public RegistryProtocol()

Method Details

setFrameworkModel

public void setFrameworkModel(FrameworkModel frameworkModel)

Specified by:

setFrameworkModel in interface ScopeModelAware

setProtocol

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

setProxyFactory

public void setProxyFactory(org.apache.dubbo.rpc.ProxyFactory proxyFactory)

getDefaultPort

public int getDefaultPort()

Specified by:

getDefaultPort in interface org.apache.dubbo.rpc.Protocol

getOverrideListeners

public Map<URL,Set<NotifyListener>> getOverrideListeners()

export

public <T> org.apache.dubbo.rpc.Exporter<T> export(org.apache.dubbo.rpc.Invoker<T> originInvoker)
                                            throws org.apache.dubbo.rpc.RpcException

Specified by:

export in interface org.apache.dubbo.rpc.Protocol

Throws:

org.apache.dubbo.rpc.RpcException

reExport

public <T> void reExport(org.apache.dubbo.rpc.Exporter<T> exporter,
 URL newInvokerUrl)

reExport

public <T> void reExport(org.apache.dubbo.rpc.Invoker<T> originInvoker,
 URL newInvokerUrl)

Reexport the invoker of the modified url

Type Parameters:

T -

Parameters:

originInvoker -

newInvokerUrl -

refer

public <T> org.apache.dubbo.rpc.Invoker<T> refer(Class<T> type,
 URL url)
                                          throws org.apache.dubbo.rpc.RpcException

Specified by:

refer in interface org.apache.dubbo.rpc.Protocol

Throws:

org.apache.dubbo.rpc.RpcException

getServiceDiscoveryInvoker

public <T> ClusterInvoker<T> getServiceDiscoveryInvoker(Cluster cluster,
 Registry registry,
 Class<T> type,
 URL url)

getInvoker

public <T> ClusterInvoker<T> getInvoker(Cluster cluster,
 Registry registry,
 Class<T> type,
 URL url)

reRefer

public <T> void reRefer(ClusterInvoker<?> invoker,
 URL newSubscribeUrl)

toSubscribeUrl

public static URL toSubscribeUrl(URL url)

destroy

public void destroy()

Specified by:

destroy in interface org.apache.dubbo.rpc.Protocol

getServers

public List<org.apache.dubbo.rpc.ProtocolServer> getServers()

Specified by:

getServers in interface org.apache.dubbo.rpc.Protocol