Package org.apache.dubbo.registry.client.migration

Class MigrationInvoker<T>

java.lang.Object

org.apache.dubbo.registry.client.migration.MigrationInvoker<T>

All Implemented Interfaces:

Node, MigrationClusterInvoker<T>, ClusterInvoker<T>, org.apache.dubbo.rpc.Invoker<T>

Direct Known Subclasses:

ServiceDiscoveryMigrationInvoker

public class MigrationInvoker<T>
extends Object
implements MigrationClusterInvoker<T>

Constructor Summary

Constructors

Constructor	Description
MigrationInvoker(RegistryProtocol registryProtocol, Cluster cluster, Registry registry, Class<T> type, URL url, URL consumerUrl)
MigrationInvoker(ClusterInvoker<T> invoker, ClusterInvoker<T> serviceDiscoveryInvoker, RegistryProtocol registryProtocol, Cluster cluster, Registry registry, Class<T> type, URL url, URL consumerUrl)

Method Summary

Modifier and Type	Method	Description
boolean	checkInvokerAvailable(ClusterInvoker<T> invoker)
void	destroy()
Cluster	getCluster()
URL	getConsumerUrl()
ClusterInvoker<T>	getCurrentAvailableInvoker()
Directory<T>	getDirectory()
Class<T>	getInterface()
ClusterInvoker<T>	getInvoker()
MigrationRule	getMigrationRule()
MigrationStep	getMigrationStep()
URL	getRegistryUrl()
ClusterInvoker<T>	getServiceDiscoveryInvoker()
URL	getUrl()
org.apache.dubbo.rpc.Result	invoke(org.apache.dubbo.rpc.Invocation invocation)
boolean	isAvailable()
boolean	isDestroyed()
boolean	isServiceDiscovery()
void	migrateToApplicationFirstInvoker(MigrationRule newRule)
boolean	migrateToForceApplicationInvoker(MigrationRule newRule)
boolean	migrateToForceInterfaceInvoker(MigrationRule newRule)
void	reRefer(URL newSubscribeUrl)
void	setInvoker(ClusterInvoker<T> invoker)
void	setMigrationRule(MigrationRule rule)
void	setMigrationStep(MigrationStep step)
void	setServiceDiscoveryInvoker(ClusterInvoker<T> serviceDiscoveryInvoker)
String	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.ClusterInvoker

hasProxyInvokers

Constructor Details

MigrationInvoker

public MigrationInvoker(RegistryProtocol registryProtocol,
 Cluster cluster,
 Registry registry,
 Class<T> type,
 URL url,
 URL consumerUrl)

MigrationInvoker

public MigrationInvoker(ClusterInvoker<T> invoker,
 ClusterInvoker<T> serviceDiscoveryInvoker,
 RegistryProtocol registryProtocol,
 Cluster cluster,
 Registry registry,
 Class<T> type,
 URL url,
 URL consumerUrl)

Method Details

getInvoker

public ClusterInvoker<T> getInvoker()

setInvoker

public void setInvoker(ClusterInvoker<T> invoker)

getServiceDiscoveryInvoker

public ClusterInvoker<T> getServiceDiscoveryInvoker()

setServiceDiscoveryInvoker

public void setServiceDiscoveryInvoker(ClusterInvoker<T> serviceDiscoveryInvoker)

getCurrentAvailableInvoker

public ClusterInvoker<T> getCurrentAvailableInvoker()

getInterface

public Class<T> getInterface()

Specified by:

getInterface in interface org.apache.dubbo.rpc.Invoker<T>

reRefer

public void reRefer(URL newSubscribeUrl)

Specified by:

reRefer in interface MigrationClusterInvoker<T>

migrateToForceInterfaceInvoker

public boolean migrateToForceInterfaceInvoker(MigrationRule newRule)

Specified by:

migrateToForceInterfaceInvoker in interface MigrationClusterInvoker<T>

migrateToForceApplicationInvoker

public boolean migrateToForceApplicationInvoker(MigrationRule newRule)

Specified by:

migrateToForceApplicationInvoker in interface MigrationClusterInvoker<T>

migrateToApplicationFirstInvoker

public void migrateToApplicationFirstInvoker(MigrationRule newRule)

Specified by:

migrateToApplicationFirstInvoker in interface MigrationClusterInvoker<T>

invoke

public org.apache.dubbo.rpc.Result invoke(org.apache.dubbo.rpc.Invocation invocation)
                                   throws org.apache.dubbo.rpc.RpcException

Specified by:

invoke in interface org.apache.dubbo.rpc.Invoker<T>

Throws:

org.apache.dubbo.rpc.RpcException

isAvailable

public boolean isAvailable()

Specified by:

isAvailable in interface Node

destroy

public void destroy()

Specified by:

destroy in interface Node

getUrl

public URL getUrl()

Specified by:

getUrl in interface Node

getRegistryUrl

public URL getRegistryUrl()

Specified by:

getRegistryUrl in interface ClusterInvoker<T>

getDirectory

public Directory<T> getDirectory()

Specified by:

getDirectory in interface ClusterInvoker<T>

isDestroyed

public boolean isDestroyed()

Specified by:

isDestroyed in interface ClusterInvoker<T>

isServiceDiscovery

public boolean isServiceDiscovery()

Specified by:

isServiceDiscovery in interface ClusterInvoker<T>

Specified by:

isServiceDiscovery in interface MigrationClusterInvoker<T>

getMigrationStep

public MigrationStep getMigrationStep()

Specified by:

getMigrationStep in interface MigrationClusterInvoker<T>

setMigrationStep

public void setMigrationStep(MigrationStep step)

Specified by:

setMigrationStep in interface MigrationClusterInvoker<T>

getMigrationRule

public MigrationRule getMigrationRule()

Specified by:

getMigrationRule in interface MigrationClusterInvoker<T>

setMigrationRule

public void setMigrationRule(MigrationRule rule)

Specified by:

setMigrationRule in interface MigrationClusterInvoker<T>

checkInvokerAvailable

public boolean checkInvokerAvailable(ClusterInvoker<T> invoker)

getCluster

public Cluster getCluster()

getConsumerUrl

public URL getConsumerUrl()

toString

public String toString()

Overrides:

toString in class Object