本文整理了Java中org.apache.camel.component.zookeeper.ZooKeeperComponent
类的一些代码示例,展示了ZooKeeperComponent
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZooKeeperComponent
类的具体详情如下:
包路径:org.apache.camel.component.zookeeper.ZooKeeperComponent
类名称:ZooKeeperComponent
[英]Component that creates ZooKeeperEndpoints for interacting with a ZooKeeper cluster.
[中]创建ZooKeeperEndpoints以与ZooKeeper群集交互的组件。
代码示例来源:origin: org.apache.camel/camel-zookeeper
protected Endpoint createEndpoint(String uri, String remaining, Map<String, Object> parameters) throws Exception {
if (getCamelContext() == null) {
throw new CamelException("No Camel context has been provided to this zookeeper component");
}
ZooKeeperConfiguration config = getConfiguration().copy();
extractConfigFromUri(uri, config);
setProperties(config, parameters);
return new ZooKeeperEndpoint(uri, this, config);
}
代码示例来源:origin: org.apache.camel/camel-zookeeper-starter
@ConditionalOnMissingBean(ZooKeeperComponent.class)
public ZooKeeperComponent configureZooKeeperComponent() throws Exception {
ZooKeeperComponent component = new ZooKeeperComponent();
component.setCamelContext(camelContext);
Map<String, Object> parameters = new HashMap<>();
IntrospectionSupport.getProperties(configuration, parameters, null,
内容来源于网络,如有侵权,请联系作者删除!