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

Class MigrationRuleListener

java.lang.Object

org.apache.dubbo.registry.client.migration.MigrationRuleListener

All Implemented Interfaces:

EventListener, ConfigurationListener, RegistryProtocolListener

@Activate
public class MigrationRuleListener
extends Object
implements RegistryProtocolListener, ConfigurationListener

Listens to from Config Center.

- Migration rule is of consumer application scope. - Listener is shared among all invokers (interfaces), it keeps the relation between interface and handler.

There are two execution points: - Refer, invoker behaviour is determined with default rule. - Rule change, invoker behaviour is changed according to the newly received rule.

Constructor Summary

Constructors

Constructor	Description
MigrationRuleListener(ModuleModel moduleModel)

Method Summary

Modifier and Type	Method	Description
Map<MigrationInvoker<?>,MigrationRuleHandler<?>>	getHandlers()
MigrationRule	getRule()
void	onDestroy()	Notify RegistryProtocol's listeners when the protocol is destroyed
void	onExport(RegistryProtocol registryProtocol, org.apache.dubbo.rpc.Exporter<?> exporter)	Notify RegistryProtocol's listeners when a service is registered
void	onRefer(RegistryProtocol registryProtocol, ClusterInvoker<?> invoker, URL consumerUrl, URL registryURL)	Notify RegistryProtocol's listeners when a service is subscribed
void	process(ConfigChangedEvent event)
void	setRawRule(String rawRule)

Methods inherited from class java.lang.Object

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

Constructor Details

MigrationRuleListener

public MigrationRuleListener(ModuleModel moduleModel)

Method Details

process

public void process(ConfigChangedEvent event)

Specified by:

process in interface ConfigurationListener

setRawRule

public void setRawRule(String rawRule)

onExport

public void onExport(RegistryProtocol registryProtocol,
 org.apache.dubbo.rpc.Exporter<?> exporter)

Description copied from interface: RegistryProtocolListener

Notify RegistryProtocol's listeners when a service is registered

Specified by:

onExport in interface RegistryProtocolListener

Parameters:

registryProtocol - RegistryProtocol instance

exporter - exporter

See Also:

• RegistryProtocol.export(org.apache.dubbo.rpc.Invoker)

onRefer

public void onRefer(RegistryProtocol registryProtocol,
 ClusterInvoker<?> invoker,
 URL consumerUrl,
 URL registryURL)

Description copied from interface: RegistryProtocolListener

Notify RegistryProtocol's listeners when a service is subscribed

Specified by:

onRefer in interface RegistryProtocolListener

Parameters:

registryProtocol - RegistryProtocol instance

invoker - invoker

consumerUrl -

See Also:

• RegistryProtocol.refer(Class, URL)

onDestroy

public void onDestroy()

Description copied from interface: RegistryProtocolListener

Notify RegistryProtocol's listeners when the protocol is destroyed

Specified by:

onDestroy in interface RegistryProtocolListener

getHandlers

public Map<MigrationInvoker<?>,MigrationRuleHandler<?>> getHandlers()

getRule

public MigrationRule getRule()