com.baidu.disconf.core.common.zookeeper.inner

Class ConnectionWatcher

java.lang.Object

com.baidu.disconf.core.common.zookeeper.inner.ConnectionWatcher

All Implemented Interfaces:

org.apache.zookeeper.Watcher

Direct Known Subclasses:

PrintZookeeperTree, ResilientActiveKeyValueStore

public class ConnectionWatcher
extends Object
implements org.apache.zookeeper.Watcher

连接管理

Author:

liaoqiqi

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.zookeeper.Watcher

org.apache.zookeeper.Watcher.Event

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	LOGGER
protected org.apache.zookeeper.ZooKeeper	zk

Constructor Summary

Constructors

Constructor and Description
ConnectionWatcher(boolean debug)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
void	connect(String hosts)
org.apache.zookeeper.ZooKeeper	getZk()
void	process(org.apache.zookeeper.WatchedEvent event) 当连接成功时调用的
void	reconnect() 含有重试机制的retry，加锁, 一直尝试连接，直至成功
void	setZk(org.apache.zookeeper.ZooKeeper zk)

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

protected static final org.slf4j.Logger LOGGER

zk

protected org.apache.zookeeper.ZooKeeper zk

Constructor Detail

ConnectionWatcher

public ConnectionWatcher(boolean debug)

Parameters:

debug -

Method Detail

connect

public void connect(String hosts)
             throws IOException,
                    InterruptedException

Parameters:

hosts -

Throws:

IOException

InterruptedException

process

public void process(org.apache.zookeeper.WatchedEvent event)

当连接成功时调用的

Specified by:

process in interface org.apache.zookeeper.Watcher

reconnect

public void reconnect()

含有重试机制的retry，加锁, 一直尝试连接，直至成功

close

public void close()
           throws InterruptedException

Throws:

InterruptedException

getZk

public org.apache.zookeeper.ZooKeeper getZk()

setZk

public void setZk(org.apache.zookeeper.ZooKeeper zk)