本文整理了Java中org.apache.camel.component.zookeeper.cluster.ZooKeeperClusterService
类的一些代码示例,展示了ZooKeeperClusterService
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZooKeeperClusterService
类的具体详情如下:
包路径:org.apache.camel.component.zookeeper.cluster.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;
}
}
内容来源于网络,如有侵权,请联系作者删除!