本文整理了Java中org.apache.eagle.alert.config.ZKConfig.<init>()
方法的一些代码示例,展示了ZKConfig.<init>()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZKConfig.<init>()
方法的具体详情如下:
包路径:org.apache.eagle.alert.config.ZKConfig
类名称:ZKConfig
方法名:<init>
暂无
代码示例来源:origin: apache/eagle
public static ZKConfig getZKConfig(Config config) {
ZKConfig zkConfig = new ZKConfig();
zkConfig.zkQuorum = config.getString("zkConfig.zkQuorum");
zkConfig.zkRoot = config.getString("zkConfig.zkRoot");
zkConfig.zkSessionTimeoutMs = config.hasPath("zkConfig.zkSessionTimeoutMs") ? config.getInt("zkConfig.zkSessionTimeoutMs") : 10000;
zkConfig.connectionTimeoutMs = config.hasPath("zkConfig.connectionTimeoutMs") ? config.getInt("zkConfig.connectionTimeoutMs") : 10000;
zkConfig.zkRetryTimes = config.hasPath("zkConfig.zkRetryTimes") ? config.getInt("zkConfig.zkRetryTimes") : 3;
zkConfig.zkRetryInterval = config.hasPath("zkConfig.zkRetryInterval") ? config.getInt("zkConfig.zkRetryInterval") : 3000;
return zkConfig;
}
}
代码示例来源:origin: apache/eagle
ZKConfig zkConfig = new ZKConfig();
zkConfig.zkQuorum = "127.0.0.1:2181";
zkConfig.zkRetryTimes = 3;
代码示例来源:origin: apache/eagle
@Before
public void setUp() throws Exception {
server = new TestingServer();
config = new ZKConfig();
config.zkQuorum = server.getConnectString();
config.zkRoot = "/alert";
config.zkRetryInterval = 1000;
config.zkRetryTimes = 3;
config.connectionTimeoutMs = 3000;
config.zkSessionTimeoutMs = 10000;
producer = new ConfigBusProducer(config);
consumer = new ConfigBusConsumer(config, topic, value -> {
validate.set(value.isValueVersionId());
configValue.set((String) value.getValue());
System.out.println("******** get notified of config " + value);
});
}
内容来源于网络,如有侵权,请联系作者删除!