[KARAF-2317] Display only up and running nodes in cluster:group-list command and CellarGroupMBean
git-svn-id: https://svn.apache.org/repos/asf/karaf/cellar/branches/cellar-2.3.x@1496387 13f79535-47bb-0310-9956-ffa450edef68 Project: http://git-wip-us.apache.org/repos/asf/karaf-cellar/repo Commit: http://git-wip-us.apache.org/repos/asf/karaf-cellar/commit/634170c2 Tree: http://git-wip-us.apache.org/repos/asf/karaf-cellar/tree/634170c2 Diff: http://git-wip-us.apache.org/repos/asf/karaf-cellar/diff/634170c2 Branch: refs/heads/cellar-2.3.x Commit: 634170c2c8c30d86973a2879213fc04dd2ca1e0d Parents: d0f4508 Author: jbonofre <jbonofre@13f79535-47bb-0310-9956-ffa450edef68> Authored: Tue Jun 25 09:06:16 2013 +0000 Committer: jbonofre <jbonofre@13f79535-47bb-0310-9956-ffa450edef68> Committed: Tue Jun 25 09:06:16 2013 +0000 ---------------------------------------------------------------------- .../management/internal/CellarGroupMBeanImpl.java | 7 +++++-- .../apache/karaf/cellar/shell/group/GroupSupport.java | 13 ++++++++----- 2 files changed, 13 insertions(+), 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/karaf-cellar/blob/634170c2/management/src/main/java/org/apache/karaf/cellar/management/internal/CellarGroupMBeanImpl.java ---------------------------------------------------------------------- diff --git a/management/src/main/java/org/apache/karaf/cellar/management/internal/CellarGroupMBeanImpl.java b/management/src/main/java/org/apache/karaf/cellar/management/internal/CellarGroupMBeanImpl.java index 834b08b..ab24cd3 100644 --- a/management/src/main/java/org/apache/karaf/cellar/management/internal/CellarGroupMBeanImpl.java +++ b/management/src/main/java/org/apache/karaf/cellar/management/internal/CellarGroupMBeanImpl.java @@ -165,8 +165,11 @@ public class CellarGroupMBeanImpl extends StandardMBean implements CellarGroupMB for (Group group : allGroups) { StringBuffer members = new StringBuffer(); for (Node node : group.getNodes()) { - members.append(node.getId()); - members.append(" "); + // display only the nodes up and running in the cluster + if (clusterManager.findNodeById(node.getId()) != null) { + members.append(node.getId()); + members.append(" "); + } } CompositeData data = new CompositeDataSupport(groupType, new String[]{ "name", "members" }, http://git-wip-us.apache.org/repos/asf/karaf-cellar/blob/634170c2/shell/src/main/java/org/apache/karaf/cellar/shell/group/GroupSupport.java ---------------------------------------------------------------------- diff --git a/shell/src/main/java/org/apache/karaf/cellar/shell/group/GroupSupport.java b/shell/src/main/java/org/apache/karaf/cellar/shell/group/GroupSupport.java index 2af6282..82539f1 100644 --- a/shell/src/main/java/org/apache/karaf/cellar/shell/group/GroupSupport.java +++ b/shell/src/main/java/org/apache/karaf/cellar/shell/group/GroupSupport.java @@ -104,12 +104,15 @@ public abstract class GroupSupport extends ClusterCommandSupport { if (g.getNodes() != null && !g.getNodes().isEmpty()) { String mark = " "; for (Node member : g.getNodes()) { - buffer.append(member.getId()); - if (member.equals(clusterManager.getNode())) { - mark = "*"; - buffer.append(mark); + // display only the up and running nodes in the cluster + if (clusterManager.findNodeById(member.getId()) != null) { + buffer.append(member.getId()); + if (member.equals(clusterManager.getNode())) { + mark = "*"; + buffer.append(mark); + } + buffer.append(" "); } - buffer.append(" "); } System.out.println(String.format(OUTPUT_FORMAT, mark, g.getName(), buffer.toString())); } else System.out.println(String.format(OUTPUT_FORMAT, "", g.getName(), ""));
