io.fabric8.groups.Group.members()方法的使用及代码示例

x33g5p2x  于2022-01-20 转载在 其他  
字(2.3k)|赞(0)|评价(0)|浏览(116)

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

Group.members介绍

[英]Get the list of members connected to this group.
[中]获取连接到此组的成员列表。

代码示例

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

@Override
public Map<String, T> members() {
  Group<T> group = this.group;
  if (group != null) {
    return group.members();
  } else {
    return Collections.emptyMap();
  }
}

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

@Override
public Map<String, T> members() {
  Group<T> group = this.group;
  if (group != null) {
    return group.members();
  } else {
    return Collections.emptyMap();
  }
}

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

@Override
  public void groupEvent(Group<ActiveMQNode> group, GroupEvent event) {
    LOG.debug("Event: " + event);
    Map<String, ActiveMQNode> masters = new HashMap<String, ActiveMQNode>();
    for (ActiveMQNode node : group.members().values()) {
      if (!masters.containsKey(node.id)) {
        masters.put(node.id, node);
      }
    }
    update(masters.values());
  }
});

代码示例来源:origin: io.fabric8.mq/mq-discovery

@Override
  public void groupEvent(Group<ActiveMQNode> group, GroupEvent event) {
    Map<String, ActiveMQNode> masters = new HashMap<String, ActiveMQNode>();
    for (ActiveMQNode node : group.members().values()) {
      if (!masters.containsKey(node.id)) {
        masters.put(node.id, node);
      }
    }
    update(masters.values());
  }
});

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

protected void onUpdate(Group<CxfNodeState> group) {
  synchronized(alternateAddressList) {
    alternateAddressList.clear();
    for (CxfNodeState node : group.members().values()) {
      if (node.services != null) {
        for (String url : node.services) {
          if (LOG.isDebugEnabled()) {
            LOG.debug("Added the CXF endpoint address " + url);
          }
          alternateAddressList.add(url);
        }
      }
    }
  }
}

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

/**
 * Re-balances all available {@link io.fabric8.partition.WorkItem} items to all available Workers.
 */
public void rebalance() {
  List<String> workItems = repository.listWorkItemLocations();
  Set<String> members = group.members().keySet();
  balancingPolicy.rebalance(context, workItems, members);
}

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

members = Collections.emptyMap();
} else {
  members = group.members();

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

members = Collections.emptyMap();
} else {
  members = group.members();

相关文章