Updated Branches: refs/heads/master 676d64ab3 -> 8b0d90ca1
removeing app path and adding topology message listner logs Project: http://git-wip-us.apache.org/repos/asf/incubator-stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-stratos/commit/a4dd80c5 Tree: http://git-wip-us.apache.org/repos/asf/incubator-stratos/tree/a4dd80c5 Diff: http://git-wip-us.apache.org/repos/asf/incubator-stratos/diff/a4dd80c5 Branch: refs/heads/master Commit: a4dd80c5158bf074c12270fb482a4c573a24d7f9 Parents: 69bad7c Author: Isuru <[email protected]> Authored: Wed Dec 18 11:02:27 2013 +0530 Committer: Isuru <[email protected]> Committed: Wed Dec 18 11:02:27 2013 +0530 ---------------------------------------------------------------------- .../stratos/adc/mgt/payload/BasicPayloadData.java | 4 ++-- .../receiver/StratosManagerTopologyReceiver.java | 15 +++++++++++++++ 2 files changed, 17 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/a4dd80c5/components/org.apache.stratos.adc.mgt/src/main/java/org/apache/stratos/adc/mgt/payload/BasicPayloadData.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.adc.mgt/src/main/java/org/apache/stratos/adc/mgt/payload/BasicPayloadData.java b/components/org.apache.stratos.adc.mgt/src/main/java/org/apache/stratos/adc/mgt/payload/BasicPayloadData.java index 2ace8b5..fc39232 100644 --- a/components/org.apache.stratos.adc.mgt/src/main/java/org/apache/stratos/adc/mgt/payload/BasicPayloadData.java +++ b/components/org.apache.stratos.adc.mgt/src/main/java/org/apache/stratos/adc/mgt/payload/BasicPayloadData.java @@ -74,8 +74,8 @@ public class BasicPayloadData implements Serializable { payloadBuilder.append(","); payloadBuilder.append("DEPLOYMENT=" + getDeployment()); payloadBuilder.append(","); - payloadBuilder.append("APP_PATH=" + getApplicationPath()); - payloadBuilder.append(","); + //payloadBuilder.append("APP_PATH=" + getApplicationPath()); + //payloadBuilder.append(","); payloadBuilder.append("GIT_REPO=" + getGitRepositoryUrl()); payloadBuilder.append(","); payloadBuilder.append("PORTS=" + getPortMappings()); http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/a4dd80c5/components/org.apache.stratos.adc.mgt/src/main/java/org/apache/stratos/adc/mgt/topology/receiver/StratosManagerTopologyReceiver.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.adc.mgt/src/main/java/org/apache/stratos/adc/mgt/topology/receiver/StratosManagerTopologyReceiver.java b/components/org.apache.stratos.adc.mgt/src/main/java/org/apache/stratos/adc/mgt/topology/receiver/StratosManagerTopologyReceiver.java index 75fdbc9..11024d6 100644 --- a/components/org.apache.stratos.adc.mgt/src/main/java/org/apache/stratos/adc/mgt/topology/receiver/StratosManagerTopologyReceiver.java +++ b/components/org.apache.stratos.adc.mgt/src/main/java/org/apache/stratos/adc/mgt/topology/receiver/StratosManagerTopologyReceiver.java @@ -59,6 +59,9 @@ public class StratosManagerTopologyReceiver implements Runnable { processorChain.addEventListener(new CompleteTopologyEventListener() { @Override protected void onEvent(Event event) { + + log.info("********** [CompleteTopologyEventListener] Received: " + event.getClass() + " **********"); + try { TopologyManager.acquireReadLock(); for (Service service : TopologyManager.getTopology().getServices()) { @@ -87,6 +90,8 @@ public class StratosManagerTopologyReceiver implements Runnable { @Override protected void onEvent(Event event) { + log.info("********** [ClusterCreatedEventListener] Received: " + event.getClass() + " **********"); + ClusterCreatedEvent clustercreatedEvent = (ClusterCreatedEvent) event; //get subscription details CartridgeSubscriptionInfo cartridgeSubscriptionInfo = @@ -119,6 +124,8 @@ public class StratosManagerTopologyReceiver implements Runnable { @Override protected void onEvent(Event event) { + log.info("********** [ClusterRemovedEventListener] Received: " + event.getClass() + " **********"); + ClusterRemovedEvent clusterRemovedEvent = (ClusterRemovedEvent) event; CartridgeSubscriptionInfo cartridgeSubscriptionInfo = @@ -138,6 +145,8 @@ public class StratosManagerTopologyReceiver implements Runnable { @Override protected void onEvent(Event event) { + log.info("********** [MemberStartedEventListener] Received: " + event.getClass() + " **********"); + MemberStartedEvent memberStartedEvent = (MemberStartedEvent) event; String clusterDomain = memberStartedEvent.getClusterId(); @@ -169,6 +178,8 @@ public class StratosManagerTopologyReceiver implements Runnable { @Override protected void onEvent(Event event) { + log.info("********** [MemberActivatedEventListener] Received: " + event.getClass() + " **********"); + MemberActivatedEvent memberActivatedEvent = (MemberActivatedEvent) event; String clusterDomain = memberActivatedEvent.getClusterId(); @@ -200,6 +211,8 @@ public class StratosManagerTopologyReceiver implements Runnable { @Override protected void onEvent(Event event) { + log.info("********** [MemberSuspendedEventListener] Received: " + event.getClass() + " **********"); + MemberSuspendedEvent memberSuspendedEvent = (MemberSuspendedEvent) event; String clusterDomain = memberSuspendedEvent.getClusterId(); @@ -231,6 +244,8 @@ public class StratosManagerTopologyReceiver implements Runnable { @Override protected void onEvent(Event event) { + log.info("********** [MemberTerminatedEventListener] Received: " + event.getClass() + " **********"); + MemberTerminatedEvent memberTerminatedEvent = (MemberTerminatedEvent) event; String clusterDomain = memberTerminatedEvent.getClusterId();
