Repository: stratos Updated Branches: refs/heads/grouping [created] b8348254c
adding topology changes for new grouping events and adding CompositeApplicationEvent receiver Project: http://git-wip-us.apache.org/repos/asf/stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/b8348254 Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/b8348254 Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/b8348254 Branch: refs/heads/grouping Commit: b8348254c569c7dcd03b37cd158c72ecc6dbca69 Parents: f8b27de Author: rekathiru <[email protected]> Authored: Fri Jul 4 13:09:26 2014 +0530 Committer: rekathiru <[email protected]> Committed: Fri Jul 4 13:09:26 2014 +0530 ---------------------------------------------------------------------- .../AutoscalerTopologyEventReceiver.java | 37 +++++++++++++++++++ .../topology/TopologyEventPublisher.java | 3 ++ .../StratosManagerTopologyEventReceiver.java | 37 +++++++++++++++++-- .../messaging/domain/topology/Cartridge.java | 14 ++++++-- .../messaging/domain/topology/Group.java | 21 ++++++----- .../messaging/domain/topology/GroupStatus.java | 38 ++++++++++++++++++++ .../util/CompositeApplicationBuilder.java | 27 ++++++-------- .../event/topology/ClusterCreatedEvent.java | 10 ++++++ .../event/topology/ClusterRemovedEvent.java | 10 ++++++ .../event/topology/MemberActivatedEvent.java | 4 +-- .../topology/MemberMaintenanceModeEvent.java | 1 + .../topology/MemberReadyToShutdownEvent.java | 1 + .../event/topology/MemberStartedEvent.java | 2 ++ .../event/topology/MemberSuspendedEvent.java | 2 ++ .../event/topology/MemberTerminatedEvent.java | 2 ++ .../topology/group/GroupActivatedEvent.java | 34 ++++++++++++++++++ .../event/topology/group/GroupCreatedEvent.java | 34 ++++++++++++++++++ .../group/GroupInMaintenanceModeEvent.java | 34 ++++++++++++++++++ .../event/topology/group/GroupStartedEvent.java | 34 ++++++++++++++++++ .../topology/group/GroupTerminatedEvent.java | 34 ++++++++++++++++++ 20 files changed, 346 insertions(+), 33 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/stratos/blob/b8348254/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/message/receiver/topology/AutoscalerTopologyEventReceiver.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/message/receiver/topology/AutoscalerTopologyEventReceiver.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/message/receiver/topology/AutoscalerTopologyEventReceiver.java index 520559c..8fd658b 100644 --- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/message/receiver/topology/AutoscalerTopologyEventReceiver.java +++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/message/receiver/topology/AutoscalerTopologyEventReceiver.java @@ -33,9 +33,17 @@ import org.apache.stratos.autoscaler.policy.PolicyManager; import org.apache.stratos.autoscaler.rule.AutoscalerRuleEvaluator; import org.apache.stratos.autoscaler.util.AutoscalerUtil; import org.apache.stratos.messaging.domain.topology.Cluster; +import org.apache.stratos.messaging.domain.topology.CompositeApplication; +import org.apache.stratos.messaging.domain.topology.ConfigCompositeApplication; import org.apache.stratos.messaging.domain.topology.Service; +import org.apache.stratos.messaging.domain.topology.util.CompositeApplicationBuilder; import org.apache.stratos.messaging.event.Event; import org.apache.stratos.messaging.event.topology.*; +import org.apache.stratos.messaging.event.topology.ClusterCreatedEvent; +import org.apache.stratos.messaging.event.topology.ClusterRemovedEvent; +import org.apache.stratos.messaging.event.topology.MemberActivatedEvent; +import org.apache.stratos.messaging.event.topology.MemberMaintenanceModeEvent; +import org.apache.stratos.messaging.event.topology.MemberTerminatedEvent; import org.apache.stratos.messaging.listener.topology.*; import org.apache.stratos.messaging.message.receiver.topology.TopologyEventReceiver; import org.apache.stratos.messaging.message.receiver.topology.TopologyManager; @@ -193,6 +201,35 @@ public class AutoscalerTopologyEventReceiver implements Runnable { }); + topologyEventReceiver.addEventListener(new CompositeApplicationCreatedEventListener() { + @Override + protected void onEvent(Event event) { + + log.info("[ClusterCreatedEventListener] Received: " + event.getClass()); + + CompositeApplicationCreatedEvent compositeApplicationCreatedEvent = (CompositeApplicationCreatedEvent) event; + + ConfigCompositeApplication configCompositeApplication = + compositeApplicationCreatedEvent.getCompositeApplication(); + + //acquire read lock + TopologyManager.acquireReadLock(); + + try { + CompositeApplication compositeApplication = + CompositeApplicationBuilder.buildCompositeApplication(TopologyManager.getTopology(), + configCompositeApplication.getAlias()); + //start the app monitor + + + } finally { + //release read lock + TopologyManager.releaseReadLock(); + } + + } + }); + topologyEventReceiver.addEventListener(new MemberTerminatedEventListener() { @Override protected void onEvent(Event event) { http://git-wip-us.apache.org/repos/asf/stratos/blob/b8348254/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/topology/TopologyEventPublisher.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/topology/TopologyEventPublisher.java b/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/topology/TopologyEventPublisher.java index d4489b4..f98515e 100644 --- a/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/topology/TopologyEventPublisher.java +++ b/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/topology/TopologyEventPublisher.java @@ -32,6 +32,9 @@ import org.apache.stratos.messaging.domain.topology.Topology; import org.apache.stratos.messaging.event.Event; import org.apache.stratos.messaging.event.instance.status.InstanceStartedEvent; import org.apache.stratos.messaging.event.topology.*; +import org.apache.stratos.messaging.event.topology.ClusterCreatedEvent; +import org.apache.stratos.messaging.event.topology.ClusterRemovedEvent; +import org.apache.stratos.messaging.event.topology.member.*; import org.apache.stratos.messaging.util.Constants; import java.util.List; http://git-wip-us.apache.org/repos/asf/stratos/blob/b8348254/components/org.apache.stratos.manager/src/main/java/org/apache/stratos/manager/topology/receiver/StratosManagerTopologyEventReceiver.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.manager/src/main/java/org/apache/stratos/manager/topology/receiver/StratosManagerTopologyEventReceiver.java b/components/org.apache.stratos.manager/src/main/java/org/apache/stratos/manager/topology/receiver/StratosManagerTopologyEventReceiver.java index 94ba486..0919ef2 100644 --- a/components/org.apache.stratos.manager/src/main/java/org/apache/stratos/manager/topology/receiver/StratosManagerTopologyEventReceiver.java +++ b/components/org.apache.stratos.manager/src/main/java/org/apache/stratos/manager/topology/receiver/StratosManagerTopologyEventReceiver.java @@ -22,11 +22,12 @@ package org.apache.stratos.manager.topology.receiver; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.stratos.manager.topology.model.TopologyClusterInformationModel; -import org.apache.stratos.messaging.domain.topology.Cluster; -import org.apache.stratos.messaging.domain.topology.Member; -import org.apache.stratos.messaging.domain.topology.Service; +import org.apache.stratos.messaging.domain.topology.*; +import org.apache.stratos.messaging.domain.topology.util.CompositeApplicationBuilder; import org.apache.stratos.messaging.event.Event; import org.apache.stratos.messaging.event.topology.*; +import org.apache.stratos.messaging.event.topology.ClusterCreatedEvent; +import org.apache.stratos.messaging.event.topology.ClusterRemovedEvent; import org.apache.stratos.messaging.listener.topology.*; import org.apache.stratos.messaging.message.receiver.topology.TopologyEventReceiver; import org.apache.stratos.messaging.message.receiver.topology.TopologyManager; @@ -101,6 +102,36 @@ public class StratosManagerTopologyEventReceiver implements Runnable { } }); + //Cluster Created event listner + topologyEventReceiver.addEventListener(new CompositeApplicationCreatedEventListener() { + @Override + protected void onEvent(Event event) { + + log.info("[ClusterCreatedEventListener] Received: " + event.getClass()); + + CompositeApplicationCreatedEvent compositeApplicationCreatedEvent = (CompositeApplicationCreatedEvent) event; + + ConfigCompositeApplication configCompositeApplication = + compositeApplicationCreatedEvent.getCompositeApplication(); + + //acquire read lock + TopologyManager.acquireReadLock(); + + try { + CompositeApplication compositeApplication = + CompositeApplicationBuilder.getInstance().buildCompositeApplication(TopologyManager.getTopology(), + configCompositeApplication.getAlias()); + //subscribe to the cluster + + + } finally { + //release read lock + TopologyManager.releaseReadLock(); + } + + } + }); + //Cluster Removed event listner topologyEventReceiver.addEventListener(new ClusterRemovedEventListener() { http://git-wip-us.apache.org/repos/asf/stratos/blob/b8348254/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/domain/topology/Cartridge.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/domain/topology/Cartridge.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/domain/topology/Cartridge.java index 55d99f0..a51fcdb 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/domain/topology/Cartridge.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/domain/topology/Cartridge.java @@ -1,11 +1,11 @@ package org.apache.stratos.messaging.domain.topology; -import java.util.ArrayList; -import java.util.List; - import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; +import java.util.ArrayList; +import java.util.List; + public class Cartridge implements Subscribable, Scalable { private String alias; // type @@ -13,6 +13,7 @@ public class Cartridge implements Subscribable, Scalable { private Dependencies dependencies; private Subscribable parent; private Group homeGroup; + private Cluster cluster; private static final Log log = LogFactory.getLog(Cartridge.class); public Cartridge(String alias) { @@ -78,4 +79,11 @@ public class Cartridge implements Subscribable, Scalable { return result; } + public Cluster getCluster() { + return cluster; + } + + public void setCluster(Cluster cluster) { + this.cluster = cluster; + } } \ No newline at end of file http://git-wip-us.apache.org/repos/asf/stratos/blob/b8348254/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/domain/topology/Group.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/domain/topology/Group.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/domain/topology/Group.java index fd76bfb..3efd4b4 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/domain/topology/Group.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/domain/topology/Group.java @@ -1,15 +1,10 @@ package org.apache.stratos.messaging.domain.topology; -import java.io.Serializable; -import java.util.ArrayList; -import java.util.HashMap; -import java.util.Iterator; -import java.util.List; -import java.util.Map; -import java.util.Set; - -import org.apache.commons.logging.LogFactory; import org.apache.commons.logging.Log; +import org.apache.commons.logging.LogFactory; + +import java.io.Serializable; +import java.util.*; public class Group implements Subscribable,Composite, Serializable { @@ -22,6 +17,7 @@ public class Group implements Subscribable,Composite, Serializable { private Dependencies dependencies; private Subscribable parent = null; private Group homeGroup; + private GroupStatus status; private static final Log log = LogFactory.getLog(Group.class); public Group(String alias) { @@ -500,4 +496,11 @@ public class Group implements Subscribable,Composite, Serializable { } + public GroupStatus getStatus() { + return status; + } + + public void setStatus(GroupStatus status) { + this.status = status; + } } http://git-wip-us.apache.org/repos/asf/stratos/blob/b8348254/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/domain/topology/GroupStatus.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/domain/topology/GroupStatus.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/domain/topology/GroupStatus.java new file mode 100644 index 0000000..2433637 --- /dev/null +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/domain/topology/GroupStatus.java @@ -0,0 +1,38 @@ +package org.apache.stratos.messaging.domain.topology;/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ + +public enum GroupStatus { + Created(1), + Starting(2), + Activated(3), + In_Maintenance(4), + Terminated(6), + Suspended(0), + ShuttingDown(0); + + private int code; + + private GroupStatus(int code) { + this.code = code; + } + + public int getCode() { + return code; + } +} http://git-wip-us.apache.org/repos/asf/stratos/blob/b8348254/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/domain/topology/util/CompositeApplicationBuilder.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/domain/topology/util/CompositeApplicationBuilder.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/domain/topology/util/CompositeApplicationBuilder.java index 73d6f9d..b8b42b5 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/domain/topology/util/CompositeApplicationBuilder.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/domain/topology/util/CompositeApplicationBuilder.java @@ -2,23 +2,9 @@ package org.apache.stratos.messaging.domain.topology.util; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; -import org.apache.stratos.messaging.domain.topology.ConfigCartridge; -import org.apache.stratos.messaging.domain.topology.ConfigGroup; -import org.apache.stratos.messaging.domain.topology.ConfigDependencies; -import org.apache.stratos.messaging.domain.topology.Cartridge; -import org.apache.stratos.messaging.domain.topology.Composite; -import org.apache.stratos.messaging.domain.topology.CompositeApplication; -import org.apache.stratos.messaging.domain.topology.ConfigCompositeApplication; -import org.apache.stratos.messaging.domain.topology.Dependencies; -import org.apache.stratos.messaging.domain.topology.Group; -import org.apache.stratos.messaging.domain.topology.Scalable; -import org.apache.stratos.messaging.domain.topology.Topology; +import org.apache.stratos.messaging.domain.topology.*; -import java.util.ArrayList; -import java.util.Collection; -import java.util.HashMap; -import java.util.List; -import java.util.Map; +import java.util.*; @@ -31,6 +17,15 @@ public class CompositeApplicationBuilder { private List<ConfigCartridge> configCartridgeArray = null; private static Log log = LogFactory.getLog(CompositeApplicationBuilder.class); + + private static CompositeApplicationBuilder instance = new CompositeApplicationBuilder(); + + public static CompositeApplicationBuilder getInstance() { + return instance; + } + + private CompositeApplicationBuilder() { + } public CompositeApplication buildCompositeApplication(Topology topology, String appAlias) { if (log.isDebugEnabled()) { http://git-wip-us.apache.org/repos/asf/stratos/blob/b8348254/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/ClusterCreatedEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/ClusterCreatedEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/ClusterCreatedEvent.java index 5d51ab8..0e7a9a5 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/ClusterCreatedEvent.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/ClusterCreatedEvent.java @@ -20,6 +20,7 @@ package org.apache.stratos.messaging.event.topology; import org.apache.stratos.messaging.domain.topology.Cluster; + import java.io.Serializable; /** @@ -31,6 +32,7 @@ public class ClusterCreatedEvent extends TopologyEvent implements Serializable { private final String serviceName; private final String clusterId; private Cluster cluster; + private String groupId; public ClusterCreatedEvent(String serviceName, String clusterId, Cluster cluster) { @@ -59,4 +61,12 @@ public class ClusterCreatedEvent extends TopologyEvent implements Serializable { public String getClusterId() { return clusterId; } + + public String getGroupId() { + return groupId; + } + + public void setGroupId(String groupId) { + this.groupId = groupId; + } } http://git-wip-us.apache.org/repos/asf/stratos/blob/b8348254/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/ClusterRemovedEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/ClusterRemovedEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/ClusterRemovedEvent.java index 43ba836..c1bf5e6 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/ClusterRemovedEvent.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/ClusterRemovedEvent.java @@ -31,6 +31,8 @@ public class ClusterRemovedEvent extends TopologyEvent implements Serializable { private final String clusterId; private final String deploymentPolicy; private final boolean isLbCluster; + private String groupId; + public ClusterRemovedEvent(String serviceName, String clusterId, String deploymentPolicy, boolean isLbCluster) { this.serviceName = serviceName; @@ -54,4 +56,12 @@ public class ClusterRemovedEvent extends TopologyEvent implements Serializable { public String getDeploymentPolicy() { return deploymentPolicy; } + + public String getGroupId() { + return groupId; + } + + public void setGroupId(String groupId) { + this.groupId = groupId; + } } http://git-wip-us.apache.org/repos/asf/stratos/blob/b8348254/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 98d82e1..38eb5c9 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 @@ -19,13 +19,13 @@ package org.apache.stratos.messaging.event.topology; +import org.apache.stratos.messaging.domain.topology.Port; + import java.io.Serializable; import java.util.Collection; import java.util.HashMap; import java.util.Map; -import org.apache.stratos.messaging.domain.topology.Port; - /** * This event is fired by Cloud Controller when a member has started it's server and * applications are ready to serve the incoming requests. http://git-wip-us.apache.org/repos/asf/stratos/blob/b8348254/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/MemberMaintenanceModeEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/MemberMaintenanceModeEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/MemberMaintenanceModeEvent.java index 8a8ea35..6340f7d 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/MemberMaintenanceModeEvent.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/MemberMaintenanceModeEvent.java @@ -19,6 +19,7 @@ package org.apache.stratos.messaging.event.topology; import org.apache.stratos.messaging.domain.topology.MemberStatus; +import org.apache.stratos.messaging.event.topology.TopologyEvent; import java.io.Serializable; import java.util.Properties; http://git-wip-us.apache.org/repos/asf/stratos/blob/b8348254/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/MemberReadyToShutdownEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/MemberReadyToShutdownEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/MemberReadyToShutdownEvent.java index 893160c..7ba3938 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/MemberReadyToShutdownEvent.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/MemberReadyToShutdownEvent.java @@ -19,6 +19,7 @@ package org.apache.stratos.messaging.event.topology; import org.apache.stratos.messaging.domain.topology.MemberStatus; +import org.apache.stratos.messaging.event.topology.TopologyEvent; import java.io.Serializable; import java.util.Properties; http://git-wip-us.apache.org/repos/asf/stratos/blob/b8348254/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/MemberStartedEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/MemberStartedEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/MemberStartedEvent.java index c9ab532..85873f1 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/MemberStartedEvent.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/MemberStartedEvent.java @@ -20,6 +20,8 @@ package org.apache.stratos.messaging.event.topology; import org.apache.stratos.messaging.domain.topology.MemberStatus; +import org.apache.stratos.messaging.event.topology.TopologyEvent; + import java.io.Serializable; import java.util.Properties; http://git-wip-us.apache.org/repos/asf/stratos/blob/b8348254/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/MemberSuspendedEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/MemberSuspendedEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/MemberSuspendedEvent.java index 5b5b113..9816ddb 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/MemberSuspendedEvent.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/MemberSuspendedEvent.java @@ -19,6 +19,8 @@ package org.apache.stratos.messaging.event.topology; +import org.apache.stratos.messaging.event.topology.TopologyEvent; + import java.io.Serializable; /** http://git-wip-us.apache.org/repos/asf/stratos/blob/b8348254/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/MemberTerminatedEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/MemberTerminatedEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/MemberTerminatedEvent.java index c35f80c..280993a 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/MemberTerminatedEvent.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/MemberTerminatedEvent.java @@ -19,6 +19,8 @@ package org.apache.stratos.messaging.event.topology; +import org.apache.stratos.messaging.event.topology.TopologyEvent; + import java.io.Serializable; /** http://git-wip-us.apache.org/repos/asf/stratos/blob/b8348254/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/group/GroupActivatedEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/group/GroupActivatedEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/group/GroupActivatedEvent.java new file mode 100644 index 0000000..effb96f --- /dev/null +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/group/GroupActivatedEvent.java @@ -0,0 +1,34 @@ +package org.apache.stratos.messaging.event.topology.group;/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ + +import org.apache.stratos.messaging.event.topology.TopologyEvent; + +import java.io.Serializable; + +public class GroupActivatedEvent extends TopologyEvent implements Serializable { + private String groupId; + + public String getGroupId() { + return groupId; + } + + public void setGroupId(String groupId) { + this.groupId = groupId; + } +} http://git-wip-us.apache.org/repos/asf/stratos/blob/b8348254/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/group/GroupCreatedEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/group/GroupCreatedEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/group/GroupCreatedEvent.java new file mode 100644 index 0000000..3d6973f --- /dev/null +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/group/GroupCreatedEvent.java @@ -0,0 +1,34 @@ +package org.apache.stratos.messaging.event.topology.group;/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ + +import org.apache.stratos.messaging.event.topology.TopologyEvent; + +import java.io.Serializable; + +public class GroupCreatedEvent extends TopologyEvent implements Serializable { + private String groupId; + + public String getGroupId() { + return groupId; + } + + public void setGroupId(String groupId) { + this.groupId = groupId; + } +} http://git-wip-us.apache.org/repos/asf/stratos/blob/b8348254/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/group/GroupInMaintenanceModeEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/group/GroupInMaintenanceModeEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/group/GroupInMaintenanceModeEvent.java new file mode 100644 index 0000000..bb2aff1 --- /dev/null +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/group/GroupInMaintenanceModeEvent.java @@ -0,0 +1,34 @@ +package org.apache.stratos.messaging.event.topology.group;/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ + +import org.apache.stratos.messaging.event.topology.TopologyEvent; + +import java.io.Serializable; + +public class GroupInMaintenanceModeEvent extends TopologyEvent implements Serializable { + private String groupId; + + public String getGroupId() { + return groupId; + } + + public void setGroupId(String groupId) { + this.groupId = groupId; + } +} http://git-wip-us.apache.org/repos/asf/stratos/blob/b8348254/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/group/GroupStartedEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/group/GroupStartedEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/group/GroupStartedEvent.java new file mode 100644 index 0000000..f504bf6 --- /dev/null +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/group/GroupStartedEvent.java @@ -0,0 +1,34 @@ +package org.apache.stratos.messaging.event.topology.group;/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ + +import org.apache.stratos.messaging.event.topology.TopologyEvent; + +import java.io.Serializable; + +public class GroupStartedEvent extends TopologyEvent implements Serializable { + private String groupId; + + public String getGroupId() { + return groupId; + } + + public void setGroupId(String groupId) { + this.groupId = groupId; + } +} http://git-wip-us.apache.org/repos/asf/stratos/blob/b8348254/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/group/GroupTerminatedEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/group/GroupTerminatedEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/group/GroupTerminatedEvent.java new file mode 100644 index 0000000..b167cc0 --- /dev/null +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/topology/group/GroupTerminatedEvent.java @@ -0,0 +1,34 @@ +package org.apache.stratos.messaging.event.topology.group;/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ + +import org.apache.stratos.messaging.event.topology.TopologyEvent; + +import java.io.Serializable; + +public class GroupTerminatedEvent extends TopologyEvent implements Serializable { + private String groupId; + + public String getGroupId() { + return groupId; + } + + public void setGroupId(String groupId) { + this.groupId = groupId; + } +}
