org.apache.camel.component.zookeeper.cluster.ZooKeeperClusterService类的使用及代码示例

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

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

ZooKeeperClusterService介绍

暂无

代码示例

代码示例来源:origin: org.apache.camel/camel-zookeeper

@Override
protected void doStart() throws Exception {
  // instantiate a new CuratorFramework
  getOrCreateCurator();
  super.doStart();
}

代码示例来源:origin: org.apache.camel/camel-zookeeper

@Override
protected ZooKeeperClusterView createView(String namespace) throws Exception {
  // Validation
  ObjectHelper.notNull(getCamelContext(), "Camel Context");
  ObjectHelper.notNull(configuration.getBasePath(), "ZooKeeper base path");
  return new ZooKeeperClusterView(this, configuration, getOrCreateCurator(), namespace);
}

代码示例来源:origin: org.apache.camel/camel-zookeeper-starter

@Bean(name = "zookeeper-cluster-service")
  @Scope(ConfigurableBeanFactory.SCOPE_SINGLETON)
  public CamelClusterService zookeeperClusterService() throws Exception {
    ZooKeeperClusterService service = new ZooKeeperClusterService();

    IntrospectionSupport.setProperties(
      service,
      IntrospectionSupport.getNonNullProperties(configuration)
    );

    return service;
  }
}

相关文章