Repository: stratos Updated Branches: refs/heads/master 175a57a7d -> efe67ad99
adding info logs for AS topology event receiver in member activated event listener Project: http://git-wip-us.apache.org/repos/asf/stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/efe67ad9 Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/efe67ad9 Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/efe67ad9 Branch: refs/heads/master Commit: efe67ad99f9fca80d4ba66c01e9b642c57838dc3 Parents: 175a57a Author: Udara Liyanage <[email protected]> Authored: Fri Jun 5 14:12:52 2015 +0530 Committer: Udara Liyanage <[email protected]> Committed: Fri Jun 5 14:12:52 2015 +0530 ---------------------------------------------------------------------- .../event/receiver/topology/AutoscalerTopologyEventReceiver.java | 1 + .../stratos/messaging/event/topology/MemberActivatedEvent.java | 4 ++++ 2 files changed, 5 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/stratos/blob/efe67ad9/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/event/receiver/topology/AutoscalerTopologyEventReceiver.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/event/receiver/topology/AutoscalerTopologyEventReceiver.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/event/receiver/topology/AutoscalerTopologyEventReceiver.java index d7ec1b4..116e5ea 100644 --- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/event/receiver/topology/AutoscalerTopologyEventReceiver.java +++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/event/receiver/topology/AutoscalerTopologyEventReceiver.java @@ -397,6 +397,7 @@ public class AutoscalerTopologyEventReceiver { try { MemberActivatedEvent memberActivatedEvent = (MemberActivatedEvent) event; String clusterId = memberActivatedEvent.getClusterId(); + log.info("MemberActivated event received for " + memberActivatedEvent.toString()); ClusterMonitor monitor; AutoscalerContext asCtx = AutoscalerContext.getInstance(); monitor = asCtx.getClusterMonitor(clusterId); http://git-wip-us.apache.org/repos/asf/stratos/blob/efe67ad9/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/MemberActivatedEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/MemberActivatedEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/MemberActivatedEvent.java index 05c0ca8..2758022 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/MemberActivatedEvent.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/MemberActivatedEvent.java @@ -58,6 +58,10 @@ public class MemberActivatedEvent extends TopologyEvent implements Serializable this.partitionId = partitionId; this.portMap = new HashMap<Integer, Port>(); } + + public String toString(){ + return String.format("[member-id] %s, [application-id] %s, [cluster-id] %s [cluster-instance-id] %s ", memberId, applicationId, clusterId, clusterInstanceId); + } public String getServiceName() { return serviceName;
