public class ClusterNodeAccessStrategy extends Object implements CanalNodeAccessStrategy
| 构造器和说明 |
|---|
ClusterNodeAccessStrategy(String destination,
com.alibaba.otter.canal.common.zookeeper.ZkClientx zkClient) |
| 限定符和类型 | 方法和说明 |
|---|---|
com.alibaba.otter.canal.common.zookeeper.ZkClientx |
getZkClient() |
SocketAddress |
nextNode() |
void |
setZkClient(com.alibaba.otter.canal.common.zookeeper.ZkClientx zkClient) |
public ClusterNodeAccessStrategy(String destination, com.alibaba.otter.canal.common.zookeeper.ZkClientx zkClient)
public SocketAddress nextNode()
nextNode 在接口中 CanalNodeAccessStrategypublic void setZkClient(com.alibaba.otter.canal.common.zookeeper.ZkClientx zkClient)
public com.alibaba.otter.canal.common.zookeeper.ZkClientx getZkClient()
Copyright © 2013. All rights reserved.