Updated Branches: refs/heads/master 5b2523a7e -> 9e5d98155
improving events adding constructors and topology listeners by removing abstract Project: http://git-wip-us.apache.org/repos/asf/incubator-stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-stratos/commit/9e5d9815 Tree: http://git-wip-us.apache.org/repos/asf/incubator-stratos/tree/9e5d9815 Diff: http://git-wip-us.apache.org/repos/asf/incubator-stratos/diff/9e5d9815 Branch: refs/heads/master Commit: 9e5d98155dccc099047058909361a5cb9ef46bdd Parents: 5b2523a Author: Lahiru Sandaruwan <[email protected]> Authored: Fri Dec 20 17:04:34 2013 +0530 Committer: Lahiru Sandaruwan <[email protected]> Committed: Fri Dec 20 17:04:34 2013 +0530 ---------------------------------------------------------------------- .../topology/AutoscalerTopologyReceiver.java | 8 ++--- .../health/stat/AverageLoadAverageEvent.java | 25 +++++++--------- .../stat/AverageMemoryConsumptionEvent.java | 25 +++++++--------- .../stat/AverageRequestsInFlightEvent.java | 24 ++++++--------- .../health/stat/GradientOfLoadAverageEvent.java | 24 ++++++--------- .../stat/GradientOfMemoryConsumptionEvent.java | 24 ++++++--------- .../stat/GradientOfRequestsInFlightEvent.java | 24 ++++++--------- .../stat/MemberAverageLoadAverageEvent.java | 17 +++++------ .../MemberAverageMemoryConsumptionEvent.java | 16 +++++----- .../event/health/stat/MemberFaultEvent.java | 31 +++++++------------- .../stat/MemberGradientOfLoadAverageEvent.java | 17 +++++------ .../MemberGradientOfMemoryConsumptionEvent.java | 17 +++++------ ...emberSecondDerivativeOfLoadAverageEvent.java | 17 +++++------ ...econdDerivativeOfMemoryConsumptionEvent.java | 17 +++++------ .../SecondDerivativeOfLoadAverageEvent.java | 24 ++++++--------- ...econdDerivativeOfMemoryConsumptionEvent.java | 17 +++++------ ...SecondDerivativeOfRequestsInFlightEvent.java | 24 ++++++--------- .../tenant/TenantRemovedEventListener.java | 7 ++++- .../topology/ClusterCreatedEventListener.java | 6 +--- .../topology/ClusterRemovedEventListener.java | 6 +--- .../topology/CompleteTopologyEventListener.java | 6 +--- .../topology/InstanceSpawnedEventListener.java | 6 +--- .../topology/MemberActivatedEventListener.java | 6 +--- .../topology/MemberStartedEventListener.java | 6 +--- .../topology/MemberSuspendedEventListener.java | 7 +---- .../topology/MemberTerminatedEventListener.java | 6 +--- .../topology/ServiceCreatedEventListener.java | 6 +--- .../topology/ServiceRemovedEventListener.java | 6 +--- 28 files changed, 154 insertions(+), 265 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/9e5d9815/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/topology/AutoscalerTopologyReceiver.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/topology/AutoscalerTopologyReceiver.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/topology/AutoscalerTopologyReceiver.java index 5ecfad9..b216df1 100644 --- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/topology/AutoscalerTopologyReceiver.java +++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/topology/AutoscalerTopologyReceiver.java @@ -218,7 +218,7 @@ public class AutoscalerTopologyReceiver implements Runnable { try { TopologyManager.acquireReadLock(); - + MemberActivatedEvent e = (MemberActivatedEvent)event; String memberId = e.getMemberId(); String partitionId = e.getPartitionId(); @@ -228,10 +228,10 @@ public class AutoscalerTopologyReceiver implements Runnable { PartitionContext partitionContext; String clusterId = e.getClusterId(); AbstractMonitor monitor; - + if(AutoscalerContext.getInstance().moniterExist(clusterId)) { monitor = AutoscalerContext.getInstance().getMonitor(clusterId); - partitionContext = monitor.getNetworkPartitionCtxt(networkPartitionId).getPartitionCtxt(partitionId); + partitionContext = monitor.getNetworkPartitionCtxt(networkPartitionId).getPartitionCtxt(partitionId); } else { monitor = AutoscalerContext.getInstance().getLBMonitor(clusterId); partitionContext = monitor.getNetworkPartitionCtxt(networkPartitionId).getPartitionCtxt(partitionId); @@ -244,7 +244,7 @@ public class AutoscalerTopologyReceiver implements Runnable { // .getPartitionCtxt(partitionId); partitionContext.incrementCurrentMemberCount(1); partitionContext.removePendingMember(memberId); - + } finally{ TopologyManager.releaseReadLock(); http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/9e5d9815/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/AverageLoadAverageEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/AverageLoadAverageEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/AverageLoadAverageEvent.java index ef28e4b..ba5abb3 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/AverageLoadAverageEvent.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/AverageLoadAverageEvent.java @@ -25,32 +25,27 @@ import org.apache.stratos.messaging.event.Event; * This event is fired by Event processing engine to send average of Load average */ public class AverageLoadAverageEvent extends Event { - private String networkPartitionId; - private String clusterId; - private float value; + private final String networkPartitionId; + private final String clusterId; + private final float value; + public AverageLoadAverageEvent(String networkPartitionId, String clusterId, float value, String networkPartitionId1, String clusterId1, float value1){ - public String getClusterId() { - return clusterId; + this.networkPartitionId = networkPartitionId1; + this.clusterId = clusterId1; + this.value = value1; } - public void setClusterId(String clusterId) { - this.clusterId = clusterId; + + public String getClusterId() { + return clusterId; } public float getValue() { return value; } - public void setValue(float value) { - this.value = value; - } - public String getNetworkPartitionId() { return networkPartitionId; } - - public void setNetworkPartitionId(String networkPartitionId) { - this.networkPartitionId = networkPartitionId; - } } http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/9e5d9815/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/AverageMemoryConsumptionEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/AverageMemoryConsumptionEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/AverageMemoryConsumptionEvent.java index b5c569a..2f13b09 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/AverageMemoryConsumptionEvent.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/AverageMemoryConsumptionEvent.java @@ -25,32 +25,27 @@ import org.apache.stratos.messaging.event.Event; * This event is fired by Event processing engine to send average of memory consumption */ public class AverageMemoryConsumptionEvent extends Event { - private String networkPartitionId; - private String clusterId; - private float value; + private final String networkPartitionId; + private final String clusterId; + private final float value; + public AverageMemoryConsumptionEvent(String networkPartitionId, String clusterId, float value){ - public String getClusterId() { - return clusterId; + this.networkPartitionId = networkPartitionId; + this.clusterId = clusterId; + this.value = value; } - public void setClusterId(String clusterId) { - this.clusterId = clusterId; + + public String getClusterId() { + return clusterId; } public float getValue() { return value; } - public void setValue(float value) { - this.value = value; - } - public String getNetworkPartitionId() { return networkPartitionId; } - - public void setNetworkPartitionId(String networkPartitionId) { - this.networkPartitionId = networkPartitionId; - } } http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/9e5d9815/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/AverageRequestsInFlightEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/AverageRequestsInFlightEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/AverageRequestsInFlightEvent.java index 0135d8f..143ae03 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/AverageRequestsInFlightEvent.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/AverageRequestsInFlightEvent.java @@ -25,32 +25,26 @@ import org.apache.stratos.messaging.event.Event; * This event is fired by Event processing engine to send average of requests in flight */ public class AverageRequestsInFlightEvent extends Event { - private String networkPartitionId; - private String clusterId; - private float value; + private final String networkPartitionId; + private final String clusterId; + private final float value; + + public AverageRequestsInFlightEvent(String networkPartitionId, String clusterId, float value) { + this.networkPartitionId = networkPartitionId; + this.clusterId = clusterId; + this.value = value; + } public String getClusterId() { return clusterId; } - public void setClusterId(String clusterId) { - this.clusterId = clusterId; - } - public float getValue() { return value; } - public void setValue(float value) { - this.value = value; - } - public String getNetworkPartitionId() { return networkPartitionId; } - - public void setNetworkPartitionId(String networkPartitionId) { - this.networkPartitionId = networkPartitionId; - } } http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/9e5d9815/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/GradientOfLoadAverageEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/GradientOfLoadAverageEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/GradientOfLoadAverageEvent.java index 5596c42..e12b35b 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/GradientOfLoadAverageEvent.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/GradientOfLoadAverageEvent.java @@ -25,32 +25,26 @@ import org.apache.stratos.messaging.event.Event; * This event is fired by Event processing engine to send gradient of Load average */ public class GradientOfLoadAverageEvent extends Event { - private String networkPartitionId; - private String clusterId; - private float value; + private final String networkPartitionId; + private final String clusterId; + private final float value; + + public GradientOfLoadAverageEvent(String networkPartitionId, String clusterId, float value) { + this.networkPartitionId = networkPartitionId; + this.clusterId = clusterId; + this.value = value; + } public String getClusterId() { return clusterId; } - public void setClusterId(String clusterId) { - this.clusterId = clusterId; - } - public float getValue() { return value; } - public void setValue(float value) { - this.value = value; - } - public String getNetworkPartitionId() { return networkPartitionId; } - - public void setNetworkPartitionId(String networkPartitionId) { - this.networkPartitionId = networkPartitionId; - } } http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/9e5d9815/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/GradientOfMemoryConsumptionEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/GradientOfMemoryConsumptionEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/GradientOfMemoryConsumptionEvent.java index 7598b76..56e43b6 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/GradientOfMemoryConsumptionEvent.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/GradientOfMemoryConsumptionEvent.java @@ -25,32 +25,26 @@ import org.apache.stratos.messaging.event.Event; * This event is fired by Event processing engine to send gradient of memory consumption */ public class GradientOfMemoryConsumptionEvent extends Event { - private String networkPartitionId; - private String clusterId; - private float value; + private final String networkPartitionId; + private final String clusterId; + private final float value; + + public GradientOfMemoryConsumptionEvent(String networkPartitionId, String clusterId, float value) { + this.networkPartitionId = networkPartitionId; + this.clusterId = clusterId; + this.value = value; + } public String getClusterId() { return clusterId; } - public void setClusterId(String clusterId) { - this.clusterId = clusterId; - } - public float getValue() { return value; } - public void setValue(float value) { - this.value = value; - } - public String getNetworkPartitionId() { return networkPartitionId; } - - public void setNetworkPartitionId(String networkPartitionId) { - this.networkPartitionId = networkPartitionId; - } } http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/9e5d9815/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/GradientOfRequestsInFlightEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/GradientOfRequestsInFlightEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/GradientOfRequestsInFlightEvent.java index fa52577..b92a985 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/GradientOfRequestsInFlightEvent.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/GradientOfRequestsInFlightEvent.java @@ -25,32 +25,26 @@ import org.apache.stratos.messaging.event.Event; * This event is fired by Event processing engine to send gradient of requests in flight */ public class GradientOfRequestsInFlightEvent extends Event { - private String networkPartitionId; - private String clusterId; - private float value; + private final String networkPartitionId; + private final String clusterId; + private final float value; + + public GradientOfRequestsInFlightEvent(String networkPartitionId, String clusterId, float value) { + this.networkPartitionId = networkPartitionId; + this.clusterId = clusterId; + this.value = value; + } public String getClusterId() { return clusterId; } - public void setClusterId(String clusterId) { - this.clusterId = clusterId; - } - public float getValue() { return value; } - public void setValue(float value) { - this.value = value; - } - public String getNetworkPartitionId() { return networkPartitionId; } - - public void setNetworkPartitionId(String networkPartitionId) { - this.networkPartitionId = networkPartitionId; - } } http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/9e5d9815/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/MemberAverageLoadAverageEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/MemberAverageLoadAverageEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/MemberAverageLoadAverageEvent.java index bacdbf0..5ad0211 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/MemberAverageLoadAverageEvent.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/MemberAverageLoadAverageEvent.java @@ -25,24 +25,21 @@ import org.apache.stratos.messaging.event.Event; * This event is fired by Event processing engine to send average of Load average */ public class MemberAverageLoadAverageEvent extends Event { - private String memberId; - private float value; + private final String memberId; + private final float value; + + public MemberAverageLoadAverageEvent(String memberId, float value) { + this.memberId = memberId; + this.value = value; + } public String getMemberId() { return memberId; } - public void setMemberId(String memberId) { - this.memberId = memberId; - } - public float getValue() { return value; } - public void setValue(float value) { - this.value = value; - } - } http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/9e5d9815/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/MemberAverageMemoryConsumptionEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/MemberAverageMemoryConsumptionEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/MemberAverageMemoryConsumptionEvent.java index 2a647e7..85025c5 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/MemberAverageMemoryConsumptionEvent.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/MemberAverageMemoryConsumptionEvent.java @@ -25,23 +25,21 @@ import org.apache.stratos.messaging.event.Event; * This event is fired by Event processing engine to send average of memory consumption */ public class MemberAverageMemoryConsumptionEvent extends Event { - private String memberId; - private float value; + private final String memberId; + private final float value; + + public MemberAverageMemoryConsumptionEvent(String memberId, float value) { + this.memberId = memberId; + this.value = value; + } public String getMemberId() { return memberId; } - public void setMemberId(String memberId) { - this.memberId = memberId; - } - public float getValue() { return value; } - public void setValue(float value) { - this.value = value; - } } http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/9e5d9815/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/MemberFaultEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/MemberFaultEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/MemberFaultEvent.java index baa6ba4..e96a4b5 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/MemberFaultEvent.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/MemberFaultEvent.java @@ -25,42 +25,33 @@ import org.apache.stratos.messaging.event.Event; * This event is fired by Event processing engine to send member fault event */ public class MemberFaultEvent extends Event { - private String clusterId; - private String memberId; - private String partitionId; + private final String clusterId; + private final String memberId; + private final String partitionId; - private float value; + private final float value; + + public MemberFaultEvent(String clusterId, String memberId, String partitionId, float value) { + this.clusterId = clusterId; + this.memberId = memberId; + this.partitionId = partitionId; + this.value = value; + } public String getClusterId() { return clusterId; } - public void setClusterId(String clusterId) { - this.clusterId = clusterId; - } - public float getValue() { return value; } - public void setValue(float value) { - this.value = value; - } - public String getPartitionId() { return partitionId; } - public void setPartitionId(String partitionId) { - this.partitionId = partitionId; - } - public String getMemberId() { return memberId; } - - public void setMemberId(String memberId) { - this.memberId = memberId; - } } http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/9e5d9815/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/MemberGradientOfLoadAverageEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/MemberGradientOfLoadAverageEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/MemberGradientOfLoadAverageEvent.java index 3f6a8e8..d0f8ae5 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/MemberGradientOfLoadAverageEvent.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/MemberGradientOfLoadAverageEvent.java @@ -26,23 +26,20 @@ import org.apache.stratos.messaging.event.Event; */ public class MemberGradientOfLoadAverageEvent extends Event { - private String memberId; - private float value; + private final String memberId; + private final float value; + + public MemberGradientOfLoadAverageEvent(String memberId, float value) { + this.memberId = memberId; + this.value = value; + } public String getMemberId() { return memberId; } - public void setMemberId(String memberId) { - this.memberId = memberId; - } - public float getValue() { return value; } - - public void setValue(float value) { - this.value = value; - } } http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/9e5d9815/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/MemberGradientOfMemoryConsumptionEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/MemberGradientOfMemoryConsumptionEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/MemberGradientOfMemoryConsumptionEvent.java index c244669..b94f5ef 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/MemberGradientOfMemoryConsumptionEvent.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/MemberGradientOfMemoryConsumptionEvent.java @@ -26,23 +26,20 @@ import org.apache.stratos.messaging.event.Event; */ public class MemberGradientOfMemoryConsumptionEvent extends Event { - private String memberId; - private float value; + private final String memberId; + private final float value; + + public MemberGradientOfMemoryConsumptionEvent(String memberId, float value) { + this.memberId = memberId; + this.value = value; + } public String getMemberId() { return memberId; } - public void setMemberId(String memberId) { - this.memberId = memberId; - } - public float getValue() { return value; } - - public void setValue(float value) { - this.value = value; - } } http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/9e5d9815/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/MemberSecondDerivativeOfLoadAverageEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/MemberSecondDerivativeOfLoadAverageEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/MemberSecondDerivativeOfLoadAverageEvent.java index 6879b27..650043f 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/MemberSecondDerivativeOfLoadAverageEvent.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/MemberSecondDerivativeOfLoadAverageEvent.java @@ -26,23 +26,20 @@ import org.apache.stratos.messaging.event.Event; */ public class MemberSecondDerivativeOfLoadAverageEvent extends Event { - private String memberId; - private float value; + private final String memberId; + private final float value; + + public MemberSecondDerivativeOfLoadAverageEvent(String memberId, float value) { + this.memberId = memberId; + this.value = value; + } public String getMemberId() { return memberId; } - public void setMemberId(String memberId) { - this.memberId = memberId; - } - public float getValue() { return value; } - - public void setValue(float value) { - this.value = value; - } } http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/9e5d9815/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/MemberSecondDerivativeOfMemoryConsumptionEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/MemberSecondDerivativeOfMemoryConsumptionEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/MemberSecondDerivativeOfMemoryConsumptionEvent.java index 1c2ae0d..532c6dd 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/MemberSecondDerivativeOfMemoryConsumptionEvent.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/MemberSecondDerivativeOfMemoryConsumptionEvent.java @@ -26,23 +26,20 @@ import org.apache.stratos.messaging.event.Event; */ public class MemberSecondDerivativeOfMemoryConsumptionEvent extends Event { - private String memberId; - private float value; + private final String memberId; + private final float value; + + public MemberSecondDerivativeOfMemoryConsumptionEvent(String memberId, float value) { + this.memberId = memberId; + this.value = value; + } public String getMemberId() { return memberId; } - public void setMemberId(String memberId) { - this.memberId = memberId; - } - public float getValue() { return value; } - - public void setValue(float value) { - this.value = value; - } } http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/9e5d9815/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/SecondDerivativeOfLoadAverageEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/SecondDerivativeOfLoadAverageEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/SecondDerivativeOfLoadAverageEvent.java index da12c41..efc54ed 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/SecondDerivativeOfLoadAverageEvent.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/SecondDerivativeOfLoadAverageEvent.java @@ -26,32 +26,26 @@ import org.apache.stratos.messaging.event.Event; */ public class SecondDerivativeOfLoadAverageEvent extends Event { - private String networkPartitionId; - private String clusterId; - private float value; + private final String networkPartitionId; + private final String clusterId; + private final float value; + + public SecondDerivativeOfLoadAverageEvent(String networkPartitionId, String clusterId, float value) { + this.networkPartitionId = networkPartitionId; + this.clusterId = clusterId; + this.value = value; + } public String getClusterId() { return clusterId; } - public void setClusterId(String clusterId) { - this.clusterId = clusterId; - } - public float getValue() { return value; } - public void setValue(float value) { - this.value = value; - } - public String getNetworkPartitionId() { return networkPartitionId; } - - public void setNetworkPartitionId(String networkPartitionId) { - this.networkPartitionId = networkPartitionId; - } } http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/9e5d9815/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/SecondDerivativeOfMemoryConsumptionEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/SecondDerivativeOfMemoryConsumptionEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/SecondDerivativeOfMemoryConsumptionEvent.java index 7abba9b..5d9e9af 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/SecondDerivativeOfMemoryConsumptionEvent.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/SecondDerivativeOfMemoryConsumptionEvent.java @@ -25,23 +25,20 @@ import org.apache.stratos.messaging.event.Event; * This event is fired by Event processing engine to send second derivative of memory consumption */ public class SecondDerivativeOfMemoryConsumptionEvent extends Event { - private String clusterId; - private float value; + private final String clusterId; + private final float value; + + public SecondDerivativeOfMemoryConsumptionEvent(String clusterId, float value) { + this.clusterId = clusterId; + this.value = value; + } public String getClusterId() { return clusterId; } - public void setClusterId(String clusterId) { - this.clusterId = clusterId; - } - public float getValue() { return value; } - - public void setValue(float value) { - this.value = value; - } } http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/9e5d9815/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/SecondDerivativeOfRequestsInFlightEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/SecondDerivativeOfRequestsInFlightEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/SecondDerivativeOfRequestsInFlightEvent.java index f659a47..cd6fe6c 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/SecondDerivativeOfRequestsInFlightEvent.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/health/stat/SecondDerivativeOfRequestsInFlightEvent.java @@ -25,32 +25,26 @@ import org.apache.stratos.messaging.event.Event; * This event is fired by Event processing engine to send second derivative of requests in flight */ public class SecondDerivativeOfRequestsInFlightEvent extends Event { - private String clusterId; - private String networkPartitionId; - private float value; + private final String clusterId; + private final String networkPartitionId; + private final float value; + + public SecondDerivativeOfRequestsInFlightEvent(String clusterId, String networkPartitionId, float value) { + this.clusterId = clusterId; + this.networkPartitionId = networkPartitionId; + this.value = value; + } public String getClusterId() { return clusterId; } - public void setClusterId(String clusterId) { - this.clusterId = clusterId; - } - public float getValue() { return value; } - public void setValue(float value) { - this.value = value; - } - public String getNetworkPartitionId() { return networkPartitionId; } - - public void setNetworkPartitionId(String networkPartitionId) { - this.networkPartitionId = networkPartitionId; - } } http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/9e5d9815/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/tenant/TenantRemovedEventListener.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/tenant/TenantRemovedEventListener.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/tenant/TenantRemovedEventListener.java index f94305f..ba75f9b 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/tenant/TenantRemovedEventListener.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/tenant/TenantRemovedEventListener.java @@ -19,10 +19,15 @@ package org.apache.stratos.messaging.listener.tenant; +import org.apache.stratos.messaging.event.Event; import org.apache.stratos.messaging.listener.EventListener; /** * Tenant removed event listener. */ -public abstract class TenantRemovedEventListener extends EventListener { +public class TenantRemovedEventListener extends EventListener { + @Override + protected void onEvent(Event event) { + + } } http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/9e5d9815/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/ClusterCreatedEventListener.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/ClusterCreatedEventListener.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/ClusterCreatedEventListener.java index 7e916e6..e1d3766 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/ClusterCreatedEventListener.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/ClusterCreatedEventListener.java @@ -19,12 +19,8 @@ package org.apache.stratos.messaging.listener.topology; -import org.apache.stratos.messaging.event.Event; import org.apache.stratos.messaging.listener.EventListener; -public class ClusterCreatedEventListener extends EventListener { +public abstract class ClusterCreatedEventListener extends EventListener { - @Override - protected void onEvent(Event event) { - } } http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/9e5d9815/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/ClusterRemovedEventListener.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/ClusterRemovedEventListener.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/ClusterRemovedEventListener.java index 5c088db..ef99ccf 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/ClusterRemovedEventListener.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/ClusterRemovedEventListener.java @@ -19,12 +19,8 @@ package org.apache.stratos.messaging.listener.topology; -import org.apache.stratos.messaging.event.Event; import org.apache.stratos.messaging.listener.EventListener; -public class ClusterRemovedEventListener extends EventListener { +public abstract class ClusterRemovedEventListener extends EventListener { - @Override - protected void onEvent(Event event) { - } } http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/9e5d9815/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/CompleteTopologyEventListener.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/CompleteTopologyEventListener.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/CompleteTopologyEventListener.java index f7b9ef4..c067b72 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/CompleteTopologyEventListener.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/CompleteTopologyEventListener.java @@ -19,12 +19,8 @@ package org.apache.stratos.messaging.listener.topology; -import org.apache.stratos.messaging.event.Event; import org.apache.stratos.messaging.listener.EventListener; -public class CompleteTopologyEventListener extends EventListener { +public abstract class CompleteTopologyEventListener extends EventListener { - @Override - protected void onEvent(Event event) { - } } http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/9e5d9815/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/InstanceSpawnedEventListener.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/InstanceSpawnedEventListener.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/InstanceSpawnedEventListener.java index 75713bd..adc16a0 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/InstanceSpawnedEventListener.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/InstanceSpawnedEventListener.java @@ -19,12 +19,8 @@ package org.apache.stratos.messaging.listener.topology; -import org.apache.stratos.messaging.event.Event; import org.apache.stratos.messaging.listener.EventListener; -public class InstanceSpawnedEventListener extends EventListener { +public abstract class InstanceSpawnedEventListener extends EventListener { - @Override - protected void onEvent(Event event) { - } } http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/9e5d9815/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/MemberActivatedEventListener.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/MemberActivatedEventListener.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/MemberActivatedEventListener.java index 951fdbf..a1b39fe 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/MemberActivatedEventListener.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/MemberActivatedEventListener.java @@ -19,12 +19,8 @@ package org.apache.stratos.messaging.listener.topology; -import org.apache.stratos.messaging.event.Event; import org.apache.stratos.messaging.listener.EventListener; -public class MemberActivatedEventListener extends EventListener { +public abstract class MemberActivatedEventListener extends EventListener { - @Override - protected void onEvent(Event event) { - } } http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/9e5d9815/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/MemberStartedEventListener.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/MemberStartedEventListener.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/MemberStartedEventListener.java index 5286c01..1e3bae0 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/MemberStartedEventListener.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/MemberStartedEventListener.java @@ -19,12 +19,8 @@ package org.apache.stratos.messaging.listener.topology; -import org.apache.stratos.messaging.event.Event; import org.apache.stratos.messaging.listener.EventListener; -public class MemberStartedEventListener extends EventListener { +public abstract class MemberStartedEventListener extends EventListener { - @Override - protected void onEvent(Event event) { - } } http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/9e5d9815/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/MemberSuspendedEventListener.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/MemberSuspendedEventListener.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/MemberSuspendedEventListener.java index 23fdd8d..8076772 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/MemberSuspendedEventListener.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/MemberSuspendedEventListener.java @@ -19,12 +19,7 @@ package org.apache.stratos.messaging.listener.topology; -import org.apache.stratos.messaging.event.Event; import org.apache.stratos.messaging.listener.EventListener; -public class MemberSuspendedEventListener extends EventListener { - - @Override - protected void onEvent(Event event) { - } +public abstract class MemberSuspendedEventListener extends EventListener { } http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/9e5d9815/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/MemberTerminatedEventListener.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/MemberTerminatedEventListener.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/MemberTerminatedEventListener.java index 202fce0..7da4cf2 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/MemberTerminatedEventListener.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/MemberTerminatedEventListener.java @@ -19,12 +19,8 @@ package org.apache.stratos.messaging.listener.topology; -import org.apache.stratos.messaging.event.Event; import org.apache.stratos.messaging.listener.EventListener; -public class MemberTerminatedEventListener extends EventListener { +public abstract class MemberTerminatedEventListener extends EventListener { - @Override - protected void onEvent(Event event) { - } } http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/9e5d9815/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/ServiceCreatedEventListener.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/ServiceCreatedEventListener.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/ServiceCreatedEventListener.java index b1d4399..e2accac 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/ServiceCreatedEventListener.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/ServiceCreatedEventListener.java @@ -19,12 +19,8 @@ package org.apache.stratos.messaging.listener.topology; -import org.apache.stratos.messaging.event.Event; import org.apache.stratos.messaging.listener.EventListener; -public class ServiceCreatedEventListener extends EventListener { +public abstract class ServiceCreatedEventListener extends EventListener { - @Override - protected void onEvent(Event event) { - } } http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/9e5d9815/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/ServiceRemovedEventListener.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/ServiceRemovedEventListener.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/ServiceRemovedEventListener.java index f9c0e58..70fc5d1 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/ServiceRemovedEventListener.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/listener/topology/ServiceRemovedEventListener.java @@ -19,12 +19,8 @@ package org.apache.stratos.messaging.listener.topology; -import org.apache.stratos.messaging.event.Event; import org.apache.stratos.messaging.listener.EventListener; -public class ServiceRemovedEventListener extends EventListener { +public abstract class ServiceRemovedEventListener extends EventListener { - @Override - protected void onEvent(Event event) { - } }
