com.twitter.distributedlog.zk.ZKWatcherManager.newBuilder()方法的使用及代码示例

x33g5p2x  于2022-02-05 转载在 其他  
字(1.3k)|赞(0)|评价(0)|浏览(95)

本文整理了Java中com.twitter.distributedlog.zk.ZKWatcherManager.newBuilder()方法的一些代码示例,展示了ZKWatcherManager.newBuilder()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZKWatcherManager.newBuilder()方法的具体详情如下:
包路径:com.twitter.distributedlog.zk.ZKWatcherManager
类名称:ZKWatcherManager
方法名:newBuilder

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)

相关文章