public class ZookeeperNodeListener extends NodeListener
+ ha-druid-datasources |---- NodeA |---- NodeB
The Data of NodeA (in Java properties format):
foo.host=xxx.xxx.xxx.xxx foo.port=3308 foo.username=foo foo.password=foo_password bar.host=xxx.xxx.xxx.xxx bar.port=3309 bar.username=bar bar.password=bar_password bar.database=bar_database
| 构造器和说明 |
|---|
ZookeeperNodeListener() |
| 限定符和类型 | 方法和说明 |
|---|---|
void |
destroy()
Close PathChildrenCache and CuratorFramework.
|
org.apache.curator.framework.CuratorFramework |
getClient() |
String |
getPath() |
String |
getUrlTemplate() |
String |
getZkConnectString() |
void |
init()
Init a PathChildrenCache to watch the given path.
|
List<NodeEvent> |
refresh()
Build Properties from PathChildrenCache.
|
void |
setClient(org.apache.curator.framework.CuratorFramework client) |
void |
setPath(String path) |
void |
setUrlTemplate(String urlTemplate) |
void |
setZkConnectString(String zkConnectString) |
getLastUpdateTime, getObserver, getPrefix, getProperties, setLastUpdateTime, setObserver, setPrefix, setProperties, update, updateaddObserver, clearChanged, countObservers, deleteObserver, deleteObservers, hasChanged, notifyObservers, notifyObservers, setChangedpublic void init()
init 在类中 NodeListenerNodeListener.setObserver(Observer)public void destroy()
destroy 在类中 NodeListenerpublic List<NodeEvent> refresh()
refresh 在类中 NodeListenergetPropertiesFromCache()public void setClient(org.apache.curator.framework.CuratorFramework client)
public org.apache.curator.framework.CuratorFramework getClient()
public String getZkConnectString()
public void setZkConnectString(String zkConnectString)
public String getPath()
public void setPath(String path)
public String getUrlTemplate()
public void setUrlTemplate(String urlTemplate)
Copyright © 2013–2023. All rights reserved.