本文整理了Java中org.I0Itec.zkclient.ZkServer.getZkClient()
方法的一些代码示例,展示了ZkServer.getZkClient()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZkServer.getZkClient()
方法的具体详情如下:
包路径:org.I0Itec.zkclient.ZkServer
类名称:ZkServer
方法名:getZkClient
暂无
代码示例来源:origin: apache/helix
public static void main(String[] args) throws Exception {
setup();
zkServer.getZkClient().setZkSerializer(new ZNRecordSerializer());
ZNRecord record = zkServer.getZkClient().readData(PropertyPathBuilder.idealState(clusterName, "TestDB"));
String externalViewPath = PropertyPathBuilder.externalView(clusterName, "TestDB");
MockSpectatorProcess process = new MockSpectatorProcess();
process.start();
// try to route, there is no master or slave available
process.routeRequest("TestDB", "TestDB_1");
// update the externalview on zookeeper
zkServer.getZkClient().createPersistent(externalViewPath, record);
// sleep for sometime so that the ZK Callback is received.
Thread.sleep(1000);
process.routeRequest("TestDB", "TestDB_1");
System.exit(1);
}
代码示例来源:origin: ezbz/projectx
@Test
@Ignore
public void test_createServer() throws Exception {
ZkServer zkServer = null;
try {
classUnderTest.afterPropertiesSet();
zkServer = classUnderTest.getObject();
assertNotNull("target object is null", zkServer);
assertNotNull("client is null", zkServer.getZkClient());
assertEquals("incorrect port", port, zkServer.getPort());
} finally {
final ZkClient zkClient = classUnderTest.getObject().getZkClient();
if (null != zkClient) {
classUnderTest.destroy();
}
}
}
}
内容来源于网络,如有侵权,请联系作者删除!