org.apache.shardingsphere.elasticjob.lite.internal.listener

Class RegistryCenterConnectionStateListener

java.lang.Object

org.apache.shardingsphere.elasticjob.lite.internal.listener.RegistryCenterConnectionStateListener

All Implemented Interfaces:

org.apache.curator.framework.state.ConnectionStateListener

public final class RegistryCenterConnectionStateListener
extends Object
implements org.apache.curator.framework.state.ConnectionStateListener

Registry center connection state listener.

Constructor Summary

Constructors

Constructor and Description
RegistryCenterConnectionStateListener(CoordinatorRegistryCenter regCenter, String jobName)

Method Summary

Modifier and Type	Method and Description
void	stateChanged(org.apache.curator.framework.CuratorFramework client, org.apache.curator.framework.state.ConnectionState newState)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.curator.framework.state.ConnectionStateListener

doNotProxy

Constructor Detail

RegistryCenterConnectionStateListener

public RegistryCenterConnectionStateListener(CoordinatorRegistryCenter regCenter,
                                             String jobName)

Method Detail

stateChanged

public void stateChanged(org.apache.curator.framework.CuratorFramework client,
                         org.apache.curator.framework.state.ConnectionState newState)

Specified by:

stateChanged in interface org.apache.curator.framework.state.ConnectionStateListener