io.fabric8.zookeeper.utils.ZooKeeperUtils.getContainerTokens()方法的使用及代码示例

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

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

ZooKeeperUtils.getContainerTokens介绍

暂无

代码示例

代码示例来源:origin: jboss-fuse/fabric8

private Properties getCachedContainerTokens(CuratorFramework curator, boolean force) throws Exception {
  if (!force && containersTs + 60000L > System.currentTimeMillis()) {
    return containers;
  }
  synchronized (this) {
    containers = getContainerTokens(curator);
    containersTs = System.currentTimeMillis();
    return containers;
  }
}

代码示例来源:origin: jboss-fuse/fabric8

Properties containers = getContainerTokens(curator);
String token = containers.getProperty(username);
if (token == null) {

代码示例来源:origin: io.fabric8/fabric-git-server

Properties containers = getContainerTokens(curator);
String token = containers.getProperty(username);
if (token == null) {

代码示例来源:origin: jboss-fuse/fabric8

private String publicPort(String containerName, final String port) {
  FabricService fabric = fabricService.get();
  Container container = fabric.getContainer(containerName);
  String user = ZooKeeperUtils.getContainerLogin(runtimeProperties.get());
  String password = "";
  try {
    Properties containerTokens = ZooKeeperUtils.getContainerTokens(obtainValid(curator));
    password = containerTokens.getProperty(user);
  } catch (Exception e) {
    LOGGER.error("Unable to get temp ZK user/pass for administrative purposes", e);
  }
  ContainerTemplate containerTemplate = new ContainerTemplate(container, user, password, false);
  return containerTemplate.execute(new JmxTemplateSupport.JmxConnectorCallback<String>() {
    @Override
    public String doWithJmxConnector(JMXConnector connector) throws Exception {
      return connector.getMBeanServerConnection().invoke(new ObjectName("io.fabric8:type=Fabric"), "getPublicPortOnCurrentContainer", new Object[]{new Integer(port)}, new String[]{"int"}).toString();
    }
  });
}

相关文章