本文整理了Java中com.twitter.distributedlog.zk.ZKWatcherManager.newBuilder()
方法的一些代码示例,展示了ZKWatcherManager.newBuilder()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZKWatcherManager.newBuilder()
方法的具体详情如下:
包路径:com.twitter.distributedlog.zk.ZKWatcherManager
类名称:ZKWatcherManager
方法名:newBuilder
暂无
代码示例来源:origin: twitter/distributedlog
ZooKeeperClient(String name,
int sessionTimeoutMs,
int connectionTimeoutMs,
String zooKeeperServers,
RetryPolicy retryPolicy,
StatsLogger statsLogger,
int retryThreadCount,
double requestRateLimit,
Credentials credentials) {
this.name = name;
this.sessionTimeoutMs = sessionTimeoutMs;
this.zooKeeperServers = zooKeeperServers;
this.defaultConnectionTimeoutMs = connectionTimeoutMs;
this.retryPolicy = retryPolicy;
this.statsLogger = statsLogger;
this.retryThreadCount = retryThreadCount;
this.requestRateLimit = requestRateLimit;
this.credentials = credentials;
this.watcherManager = ZKWatcherManager.newBuilder()
.name(name)
.statsLogger(statsLogger.scope("watcher_manager"))
.build();
}
代码示例来源:origin: twitter/distributedlog
@Test(timeout = 60000)
public void testRegisterUnregisterWatcher() throws Exception {
ZKWatcherManager watcherManager = ZKWatcherManager.newBuilder()
.name("test-register-unregister-watcher")
.statsLogger(NullStatsLogger.INSTANCE)
内容来源于网络,如有侵权,请联系作者删除!