org.tinygroup.remoteconfig.zk.client

Class ZKPublishManager

java.lang.Object

org.tinygroup.remoteconfig.zk.client.BaseManager

org.tinygroup.remoteconfig.zk.client.ZKPublishManager

public class ZKPublishManager
extends BaseManager

发布监控manager

Version:

$Id: ZKPublishManager.java, v 0.1 2017-12-19 下午8:46:29 zhangliang08072 Exp $

Author:

zhangliang08072

Field Summary

Fields inherited from class org.tinygroup.remoteconfig.zk.client.BaseManager

config, curator

Constructor Summary

Constructors

Constructor and Description
ZKPublishManager()

Method Summary

Modifier and Type	Method and Description
static void	addSessionTimeoutHandler(org.apache.curator.framework.state.ConnectionStateListener listener)
static ConfigPublishItem	get(String clientId, ConfigPath configPath)
static ConfigPath	getConfigPath()
static Map<String,ConfigPublishItem>	getConfigPublishItems(ConfigPath configPath)
static org.apache.curator.framework.recipes.cache.NodeCache	getNodeCache()
static void	set(String clientId, ConfigPublishItem item, ConfigPath configPath) 生成或修改配置项变更的监控节点
static void	setConfigPath(ConfigPath configPath)
static void	startWatch(String clientId, org.apache.curator.framework.recipes.cache.NodeCacheListener listener) 发起监控
static void	stopWatch() 停止监控配置项发布
static void	update(String clientId, ConfigPublishItem item, ConfigPath configPath) 仅修改配置项变更的监控节点

Methods inherited from class org.tinygroup.remoteconfig.zk.client.BaseManager

delete, exists, getConfig, setConfig, start, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

ZKPublishManager

public ZKPublishManager()

Method Detail

set

public static void set(String clientId,
                       ConfigPublishItem item,
                       ConfigPath configPath)

生成或修改配置项变更的监控节点

Parameters:

clientId - 客户端Id

item - 节点存储数据

configPath - 客户端对应的环境

update

public static void update(String clientId,
                          ConfigPublishItem item,
                          ConfigPath configPath)

仅修改配置项变更的监控节点

Parameters:

clientId -

item -

configPath -

get

public static ConfigPublishItem get(String clientId,
                                    ConfigPath configPath)

getConfigPublishItems

public static Map<String,ConfigPublishItem> getConfigPublishItems(ConfigPath configPath)

startWatch

public static void startWatch(String clientId,
                              org.apache.curator.framework.recipes.cache.NodeCacheListener listener)

发起监控

Parameters:

clientId -

listener -

stopWatch

public static void stopWatch()

停止监控配置项发布

addSessionTimeoutHandler

public static void addSessionTimeoutHandler(org.apache.curator.framework.state.ConnectionStateListener listener)

setConfigPath

public static void setConfigPath(ConfigPath configPath)

getConfigPath

public static ConfigPath getConfigPath()

getNodeCache

public static org.apache.curator.framework.recipes.cache.NodeCache getNodeCache()