Updated Branches: refs/heads/master 3bb7f1b6c -> 92b4b1e18
adding debug logs to print members Project: http://git-wip-us.apache.org/repos/asf/incubator-stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-stratos/commit/92b4b1e1 Tree: http://git-wip-us.apache.org/repos/asf/incubator-stratos/tree/92b4b1e1 Diff: http://git-wip-us.apache.org/repos/asf/incubator-stratos/diff/92b4b1e1 Branch: refs/heads/master Commit: 92b4b1e18693c7f7c779fae76fbf97e9c1a5afae Parents: 3bb7f1b Author: Isuru <[email protected]> Authored: Fri Feb 7 14:54:53 2014 +0530 Committer: Isuru <[email protected]> Committed: Fri Feb 7 14:54:53 2014 +0530 ---------------------------------------------------------------------- .../model/TopologyClusterInformationModel.java | 41 +++++++++++++++++++- 1 file changed, 39 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/92b4b1e1/components/org.apache.stratos.manager/src/main/java/org/apache/stratos/manager/topology/model/TopologyClusterInformationModel.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.manager/src/main/java/org/apache/stratos/manager/topology/model/TopologyClusterInformationModel.java b/components/org.apache.stratos.manager/src/main/java/org/apache/stratos/manager/topology/model/TopologyClusterInformationModel.java index a30f7d6..546f6b2 100644 --- a/components/org.apache.stratos.manager/src/main/java/org/apache/stratos/manager/topology/model/TopologyClusterInformationModel.java +++ b/components/org.apache.stratos.manager/src/main/java/org/apache/stratos/manager/topology/model/TopologyClusterInformationModel.java @@ -22,6 +22,7 @@ package org.apache.stratos.manager.topology.model; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.stratos.messaging.domain.topology.Cluster; +import org.apache.stratos.messaging.domain.topology.Member; import java.util.*; import java.util.concurrent.locks.ReentrantReadWriteLock; @@ -93,7 +94,13 @@ public class TopologyClusterInformationModel { cartridgeTypeContextSet.add(cartridgeTypeContext); if (log.isDebugEnabled()) { - log.debug("New cluster added " + cluster.toString()); + log.debug("New cluster added : " + cluster.toString()); + Collection<Member> members = cluster.getMembers(); + if (members != null && !members.isEmpty()) { + for (Member member : members) { + log.debug("[ " + member.getServiceName() + ", " + member.getClusterId() + ", "+ member.getMemberId() + " ]"); + } + } } } else { @@ -116,6 +123,12 @@ public class TopologyClusterInformationModel { if (log.isDebugEnabled()) { log.debug("Existing cluster found, updated : " + cluster.toString()); + Collection<Member> members = cluster.getMembers(); + if (members != null && !members.isEmpty()) { + for (Member member : members) { + log.debug("[ " + member.getServiceName() + ", " + member.getClusterId() + ", "+ member.getMemberId() + " ]"); + } + } } } @@ -144,7 +157,13 @@ public class TopologyClusterInformationModel { tenantIdToCartridgeTypeContextMap.put(tenantId, cartridgeTypeContextSet); if (log.isDebugEnabled()) { - log.debug("New cluster added " + cluster.toString()); + log.debug("New cluster added : " + cluster.toString()); + Collection<Member> members = cluster.getMembers(); + if (members != null && !members.isEmpty()) { + for (Member member : members) { + log.debug("[ " + member.getServiceName() + ", " + member.getClusterId() + ", "+ member.getMemberId() + " ]"); + } + } } } @@ -186,6 +205,12 @@ public class TopologyClusterInformationModel { if (log.isDebugEnabled()) { log.debug("Matching cluster found for tenant " + tenantId + ", type " + cartridgeType + ", subscription alias " + subscriptionAlias + ": " + subscriptionAliasContext.getCluster().toString()); + Collection<Member> members = subscriptionAliasContext.getCluster().getMembers(); + if (members != null && !members.isEmpty()) { + for (Member member : members) { + log.debug("[ " + member.getServiceName() + ", " + member.getClusterId() + ", "+ member.getMemberId() + " ]"); + } + } } return subscriptionAliasContext.getCluster(); @@ -235,6 +260,12 @@ public class TopologyClusterInformationModel { if (log.isDebugEnabled()) { log.debug("Matching cluster found for tenant " + tenantId + " : " + cluster.toString()); + Collection<Member> members = cluster.getMembers(); + if (members != null && !members.isEmpty()) { + for (Member member : members) { + log.debug("[ " + member.getServiceName() + ", " + member.getClusterId() + ", "+ member.getMemberId() + " ]"); + } + } } } } @@ -256,6 +287,12 @@ public class TopologyClusterInformationModel { if (log.isDebugEnabled()) { log.debug("Matching cluster found for tenant " + tenantId + ", type " + cartridgeType + " : " + cluster.toString()); + Collection<Member> members = cluster.getMembers(); + if (members != null && !members.isEmpty()) { + for (Member member : members) { + log.debug("[ " + member.getServiceName() + ", " + member.getClusterId() + ", "+ member.getMemberId() + " ]"); + } + } } } }
