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

ZooKeeperNode.getAttribute介绍

暂无

代码示例

代码示例来源：origin: org.apache.brooklyn/brooklyn-software-messaging

@Override
  public Void call() {
    assertTrue(cluster.getAttribute(Startable.SERVICE_UP));
    assertTrue(cluster.getZooKeeper().getAttribute(Startable.SERVICE_UP));
    assertEquals(cluster.getCurrentSize().intValue(), 2);
    return null;
  }
});

代码示例来源：origin: org.apache.brooklyn/brooklyn-software-messaging

@Override
  public Void call() {
    assertTrue(cluster.getAttribute(Startable.SERVICE_UP));
    assertTrue(cluster.getZooKeeper().getAttribute(Startable.SERVICE_UP));
    assertEquals(cluster.getCurrentSize().intValue(), 2);
    return null;
  }
});

代码示例来源：origin: org.apache.brooklyn/brooklyn-software-messaging

/** Use the {@link #getZookeeper() zookeeper} details if available, otherwise use our own host and port. */
@Override
public void setBrokerUrl() {
  ZooKeeperNode zookeeper = getZookeeper();
  if (zookeeper != null) {
    sensors().set(BROKER_URL, String.format("zookeeper://%s:%d", zookeeper.getAttribute(HOSTNAME), zookeeper.getZookeeperPort()));
  } else {
    sensors().set(BROKER_URL, String.format("kafka://%s:%d", getAttribute(HOSTNAME), getKafkaPort()));
  }
}