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