renaming application.status topic to applications
Project: http://git-wip-us.apache.org/repos/asf/stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/f0ba4beb Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/f0ba4beb Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/f0ba4beb Branch: refs/heads/docker-grouping-merge Commit: f0ba4beb168eb119011aef6c424cc4d60057585b Parents: e153430 Author: reka <[email protected]> Authored: Fri Oct 31 12:22:29 2014 +0530 Committer: reka <[email protected]> Committed: Fri Oct 31 12:23:39 2014 +0530 ---------------------------------------------------------------------- .../grouping/topic/StatusEventPublisher.java | 54 +++---- .../status/checker/StatusChecker.java | 62 ++++++++- .../AppStatusApplicationActivatedEvent.java | 38 ----- .../AppStatusApplicationCreatedEvent.java | 38 ----- .../AppStatusApplicationInactivatedEvent.java | 38 ----- .../AppStatusApplicationTerminatedEvent.java | 47 ------- .../AppStatusApplicationTerminatingEvent.java | 38 ----- .../status/AppStatusClusterActivatedEvent.java | 50 ------- .../status/AppStatusClusterCreatedEvent.java | 50 ------- .../status/AppStatusClusterInactivateEvent.java | 50 ------- .../AppStatusClusterMaintenanceModeEvent.java | 49 ------- .../AppStatusClusterReadyToShutdownEvent.java | 47 ------- .../status/AppStatusClusterTerminatedEvent.java | 50 ------- .../AppStatusClusterTerminatingEvent.java | 50 ------- .../status/AppStatusGroupActivatedEvent.java | 44 ------ .../status/AppStatusGroupCreatedEvent.java | 44 ------ .../status/AppStatusGroupInactivateEvent.java | 44 ------ .../AppStatusGroupMaintenanceModeEvent.java | 41 ------ .../AppStatusGroupReadyToShutdownEvent.java | 40 ------ .../status/AppStatusGroupTerminatedEvent.java | 44 ------ .../status/AppStatusGroupTerminatingEvent.java | 44 ------ .../event/application/status/StatusEvent.java | 31 ----- .../applications/AppClusterActivatedEvent.java | 50 +++++++ .../applications/AppClusterCreatedEvent.java | 50 +++++++ .../applications/AppClusterInactivateEvent.java | 50 +++++++ .../applications/AppClusterTerminatedEvent.java | 50 +++++++ .../AppClusterTerminatingEvent.java | 50 +++++++ .../AppStatusGroupInactivateEvent.java | 44 ++++++ .../applications/ApplicationActivatedEvent.java | 38 +++++ .../applications/ApplicationCreatedEvent.java | 38 +++++ .../ApplicationInactivatedEvent.java | 38 +++++ .../ApplicationTerminatedEvent.java | 47 +++++++ .../ApplicationTerminatingEvent.java | 38 +++++ .../event/applications/GroupActivatedEvent.java | 44 ++++++ .../event/applications/GroupCreatedEvent.java | 44 ++++++ .../applications/GroupMaintenanceModeEvent.java | 41 ++++++ .../applications/GroupReadyToShutdownEvent.java | 40 ++++++ .../applications/GroupTerminatedEvent.java | 44 ++++++ .../applications/GroupTerminatingEvent.java | 44 ++++++ .../event/applications/StatusEvent.java | 31 +++++ ...StatusApplicationActivatedEventListener.java | 27 ---- ...ppStatusApplicationCreatedEventListener.java | 27 ---- ...atusApplicationInactivatedEventListener.java | 27 ---- ...tatusApplicationTerminatedEventListener.java | 27 ---- ...atusApplicationTerminatingEventListener.java | 27 ---- .../AppStatusClusterActivatedEventListener.java | 24 ---- .../AppStatusClusterCreatedEventListener.java | 24 ---- ...AppStatusClusterInactivateEventListener.java | 24 ---- ...AppStatusClusterTerminatedEventListener.java | 24 ---- ...ppStatusClusterTerminatingEventListener.java | 24 ---- .../AppStatusGroupActivatedEventListener.java | 24 ---- .../AppStatusGroupCreatedEventListener.java | 24 ---- .../AppStatusGroupInactivateEventListener.java | 24 ---- .../AppStatusGroupTerminatedEventListener.java | 24 ---- .../AppStatusGroupTerminatingEventListener.java | 24 ---- .../AppClusterActivatedEventListener.java | 24 ++++ .../AppClusterCreatedEventListener.java | 24 ++++ .../AppClusterInactivateEventListener.java | 24 ++++ .../AppClusterTerminatedEventListener.java | 24 ++++ .../AppClusterTerminatingEventListener.java | 24 ++++ .../ApplicationActivatedEventListener.java | 27 ++++ .../ApplicationCreatedEventListener.java | 27 ++++ .../ApplicationInactivatedEventListener.java | 27 ++++ .../ApplicationTerminatedEventListener.java | 27 ++++ .../ApplicationTerminatingEventListener.java | 27 ++++ .../ApplicationUndeployedEventListener.java | 26 ++++ .../GroupActivatedEventListener.java | 24 ++++ .../applications/GroupCreatedEventListener.java | 24 ++++ .../GroupInactivateEventListener.java | 24 ++++ .../GroupTerminatedEventListener.java | 24 ++++ .../GroupTerminatingEventListener.java | 24 ++++ .../ApplicationActivatedEventListener.java | 27 ---- .../ApplicationCreatedEventListener.java | 26 ---- .../ApplicationInActivateEventListener.java | 27 ---- .../ApplicationTerminatedEventListener.java | 27 ---- .../ApplicationTerminatingEventListener.java | 27 ---- .../ApplicationUndeployedEventListener.java | 26 ---- .../topology/GroupActivatedEventListener.java | 27 ---- .../topology/GroupCreatedEventListener.java | 27 ---- .../topology/GroupInActivateEventListener.java | 27 ---- .../topology/GroupTerminatedEventListener.java | 27 ---- .../topology/GroupTerminatingEventListener.java | 27 ---- ...tusApplicationActivatedMessageProcessor.java | 62 --------- ...tatusApplicationCreatedMessageProcessor.java | 63 --------- ...sApplicationInactivatedMessageProcessor.java | 63 --------- ...usApplicationTerminatedMessageProcessor.java | 63 --------- ...sApplicationTerminatingMessageProcessor.java | 63 --------- ...pStatusClusterActivatedMessageProcessor.java | 57 -------- ...AppStatusClusterCreatedMessageProcessor.java | 58 -------- ...StatusClusterInactivateMessageProcessor.java | 58 -------- ...StatusClusterTerminatedMessageProcessor.java | 58 -------- ...tatusClusterTerminatingMessageProcessor.java | 58 -------- ...AppStatusGroupActivatedMessageProcessor.java | 61 -------- .../AppStatusGroupCreatedMessageProcessor.java | 62 --------- ...pStatusGroupInactivatedMessageProcessor.java | 61 -------- ...ppStatusGroupTerminatedMessageProcessor.java | 61 -------- ...pStatusGroupTerminatingMessageProcessor.java | 61 -------- .../status/AppStatusMessageProcessorChain.java | 139 ------------------- .../AppClusterActivatedMessageProcessor.java | 57 ++++++++ .../AppClusterCreatedMessageProcessor.java | 57 ++++++++ .../AppClusterInactivateMessageProcessor.java | 58 ++++++++ .../AppClusterTerminatedMessageProcessor.java | 58 ++++++++ .../AppClusterTerminatingMessageProcessor.java | 58 ++++++++ .../AppStatusMessageProcessorChain.java | 139 +++++++++++++++++++ .../ApplicationActivatedMessageProcessor.java | 62 +++++++++ .../ApplicationCreatedMessageProcessor.java | 63 +++++++++ .../ApplicationInactivatedMessageProcessor.java | 63 +++++++++ .../ApplicationTerminatedMessageProcessor.java | 63 +++++++++ .../ApplicationTerminatingMessageProcessor.java | 63 +++++++++ .../GroupActivatedMessageProcessor.java | 61 ++++++++ .../GroupCreatedMessageProcessor.java | 61 ++++++++ .../GroupInactivatedMessageProcessor.java | 61 ++++++++ .../GroupTerminatedMessageProcessor.java | 61 ++++++++ .../GroupTerminatingMessageProcessor.java | 61 ++++++++ 114 files changed, 2316 insertions(+), 2623 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/stratos/blob/f0ba4beb/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/grouping/topic/StatusEventPublisher.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/grouping/topic/StatusEventPublisher.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/grouping/topic/StatusEventPublisher.java index eb6e084..c0e77de 100644 --- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/grouping/topic/StatusEventPublisher.java +++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/grouping/topic/StatusEventPublisher.java @@ -7,7 +7,7 @@ import org.apache.stratos.messaging.broker.publish.EventPublisherPool; import org.apache.stratos.messaging.domain.applications.*; import org.apache.stratos.messaging.domain.topology.*; import org.apache.stratos.messaging.event.Event; -import org.apache.stratos.messaging.event.application.status.*; +import org.apache.stratos.messaging.event.applications.*; import org.apache.stratos.messaging.message.receiver.topology.TopologyManager; import org.apache.stratos.messaging.util.Constants; @@ -30,8 +30,8 @@ public class StatusEventPublisher { log.info("Publishing Cluster created event for [application]: " + appId + " [cluster]: " + clusterId); } - AppStatusClusterCreatedEvent clusterCreatedEvent = - new AppStatusClusterCreatedEvent(appId, serviceName, clusterId); + AppClusterCreatedEvent clusterCreatedEvent = + new AppClusterCreatedEvent(appId, serviceName, clusterId); publishEvent(clusterCreatedEvent); } else { @@ -54,8 +54,8 @@ public class StatusEventPublisher { log.info("Publishing Cluster activated event for [application]: " + appId + " [cluster]: " + clusterId); } - AppStatusClusterActivatedEvent clusterActivatedEvent = - new AppStatusClusterActivatedEvent(appId, serviceName, clusterId); + AppClusterActivatedEvent clusterActivatedEvent = + new AppClusterActivatedEvent(appId, serviceName, clusterId); publishEvent(clusterActivatedEvent); } else { @@ -78,8 +78,8 @@ public class StatusEventPublisher { log.info("Publishing Cluster in-activate event for [application]: " + appId + " [cluster]: " + clusterId); } - AppStatusClusterInactivateEvent clusterInActivateEvent = - new AppStatusClusterInactivateEvent(appId, serviceName, clusterId); + AppClusterInactivateEvent clusterInActivateEvent = + new AppClusterInactivateEvent(appId, serviceName, clusterId); publishEvent(clusterInActivateEvent); } else { @@ -104,8 +104,8 @@ public class StatusEventPublisher { log.info("Publishing Cluster Terminating event for [application]: " + appId + " [cluster]: " + clusterId); } - AppStatusClusterTerminatingEvent appStatusClusterTerminatingEvent = - new AppStatusClusterTerminatingEvent(appId, serviceName, clusterId); + AppClusterTerminatingEvent appStatusClusterTerminatingEvent = + new AppClusterTerminatingEvent(appId, serviceName, clusterId); publishEvent(appStatusClusterTerminatingEvent); } else { @@ -130,8 +130,8 @@ public class StatusEventPublisher { log.info("Publishing Cluster terminated event for [application]: " + appId + " [cluster]: " + clusterId); } - AppStatusClusterTerminatedEvent appStatusClusterTerminatedEvent = - new AppStatusClusterTerminatedEvent(appId, serviceName, clusterId); + AppClusterTerminatedEvent appStatusClusterTerminatedEvent = + new AppClusterTerminatedEvent(appId, serviceName, clusterId); publishEvent(appStatusClusterTerminatedEvent); } else { @@ -155,8 +155,8 @@ public class StatusEventPublisher { log.info("Publishing Group created event for [application]: " + appId + " [group]: " + groupId); } - AppStatusGroupCreatedEvent groupCreatedEvent = - new AppStatusGroupCreatedEvent(appId, groupId); + GroupCreatedEvent groupCreatedEvent = + new GroupCreatedEvent(appId, groupId); publishEvent(groupCreatedEvent); } else { @@ -179,8 +179,8 @@ public class StatusEventPublisher { log.info("Publishing Group activated event for [application]: " + appId + " [group]: " + groupId); } - AppStatusGroupActivatedEvent groupActivatedEvent = - new AppStatusGroupActivatedEvent(appId, groupId); + GroupActivatedEvent groupActivatedEvent = + new GroupActivatedEvent(appId, groupId); publishEvent(groupActivatedEvent); } else { @@ -227,8 +227,8 @@ public class StatusEventPublisher { log.info("Publishing Group terminating event for [application]: " + appId + " [group]: " + groupId); } - AppStatusGroupTerminatingEvent groupInTerminatingEvent = - new AppStatusGroupTerminatingEvent(appId, groupId); + GroupTerminatingEvent groupInTerminatingEvent = + new GroupTerminatingEvent(appId, groupId); publishEvent(groupInTerminatingEvent); } else { log.warn("Terminating is not in the possible state list of [group] " + groupId); @@ -252,8 +252,8 @@ public class StatusEventPublisher { if (application != null) { Group group = application.getGroupRecursively(groupId); if (group.isStateTransitionValid(GroupStatus.Terminated)) { - AppStatusGroupTerminatedEvent groupInTerminatedEvent = - new AppStatusGroupTerminatedEvent(appId, groupId); + GroupTerminatedEvent groupInTerminatedEvent = + new GroupTerminatedEvent(appId, groupId); publishEvent(groupInTerminatedEvent); } else { log.warn("Terminated is not in the possible state list of [group] " + groupId); @@ -275,8 +275,8 @@ public class StatusEventPublisher { if (log.isInfoEnabled()) { log.info("Publishing Application activated event for [application]: " + appId); } - AppStatusApplicationActivatedEvent applicationActivatedEvent = - new AppStatusApplicationActivatedEvent(appId); + ApplicationActivatedEvent applicationActivatedEvent = + new ApplicationActivatedEvent(appId); publishEvent(applicationActivatedEvent); } else { @@ -298,8 +298,8 @@ public class StatusEventPublisher { Application application = TopologyManager.getTopology().getApplication(appId); if (application != null) { if (application.isStateTransitionValid(ApplicationStatus.Inactive)) { - AppStatusApplicationInactivatedEvent applicationInActivatedEvent = - new AppStatusApplicationInactivatedEvent(appId); + ApplicationInactivatedEvent applicationInActivatedEvent = + new ApplicationInactivatedEvent(appId); publishEvent(applicationInActivatedEvent); } else { log.warn("Inactive is not in the possible state list of [application] " + appId); @@ -319,8 +319,8 @@ public class StatusEventPublisher { if (log.isInfoEnabled()) { log.info("Publishing Application terminated event for [application]: " + appId); } - AppStatusApplicationTerminatingEvent applicationTerminatingEvent = - new AppStatusApplicationTerminatingEvent(appId); + ApplicationTerminatingEvent applicationTerminatingEvent = + new ApplicationTerminatingEvent(appId); publishEvent(applicationTerminatingEvent); } else { log.warn("Terminating is not in the possible state list of [application] " + appId); @@ -340,8 +340,8 @@ public class StatusEventPublisher { if (log.isInfoEnabled()) { log.info("Publishing Application terminated event for [application]: " + appId); } - AppStatusApplicationTerminatedEvent applicationTerminatedEvent = - new AppStatusApplicationTerminatedEvent(appId, clusterData); + ApplicationTerminatedEvent applicationTerminatedEvent = + new ApplicationTerminatedEvent(appId, clusterData); publishEvent(applicationTerminatedEvent); } else { log.warn("Terminated is not in the possible state list of [application] " + appId); http://git-wip-us.apache.org/repos/asf/stratos/blob/f0ba4beb/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/status/checker/StatusChecker.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/status/checker/StatusChecker.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/status/checker/StatusChecker.java index 392a0d5..408776f 100644 --- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/status/checker/StatusChecker.java +++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/status/checker/StatusChecker.java @@ -30,6 +30,7 @@ import org.apache.stratos.messaging.domain.applications.*; import org.apache.stratos.messaging.domain.topology.*; import org.apache.stratos.messaging.message.receiver.topology.TopologyManager; +import javax.net.ssl.SSLEngineResult; import java.util.Map; /** @@ -287,7 +288,7 @@ public class StatusChecker { TopologyManager.acquireReadLockForApplication(appId); Application application = TopologyManager.getTopology().getApplication(appId); - if (groups.isEmpty() && clusterStatus == ClusterStatus.Active || + if (groups.isEmpty() && getClusterAllInSameState(clusterData,ClusterStatus.Active) || clusterData.isEmpty() && groupStatus == GroupStatus.Active || groupStatus == GroupStatus.Active && clusterStatus == ClusterStatus.Active) { //send activation event @@ -369,6 +370,65 @@ public class StatusChecker { return childFound; } + private boolean getGroupInActive(Map<String, Group> groups) { + boolean groupStat = false; + for (Group group : groups.values()) { + if (group.getStatus() == GroupStatus.Inactive) { + groupStat = true; + return groupStat; + } else { + groupStat = false; + } + } + return groupStat; + } + + private boolean allGroupInSameState(Map<String, Group> groups, GroupStatus status) { + boolean groupStat = false; + for (Group group : groups.values()) { + if (group.getStatus() == status) { + groupStat = true; + } else { + groupStat = false; + return groupStat; + } + } + return groupStat; + } + + + private boolean getClusterInActive(Map<String, ClusterDataHolder> clusterData) { + boolean clusterStat = false; + for (Map.Entry<String, ClusterDataHolder> clusterDataHolderEntry : clusterData.entrySet()) { + Service service = TopologyManager.getTopology().getService(clusterDataHolderEntry.getValue().getServiceType()); + Cluster cluster = service.getCluster(clusterDataHolderEntry.getValue().getClusterId()); + if (cluster.getStatus() == ClusterStatus.Inactive) { + clusterStat = true; + return clusterStat; + } else { + clusterStat = false; + + } + } + return clusterStat; + } + + private boolean getClusterAllInSameState(Map<String, ClusterDataHolder> clusterData, + ClusterStatus status) { + boolean clusterStat = false; + for (Map.Entry<String, ClusterDataHolder> clusterDataHolderEntry : clusterData.entrySet()) { + Service service = TopologyManager.getTopology().getService(clusterDataHolderEntry.getValue().getServiceType()); + Cluster cluster = service.getCluster(clusterDataHolderEntry.getValue().getClusterId()); + if (cluster.getStatus() == status) { + clusterStat = true; + } else { + clusterStat = false; + return clusterStat; + } + } + return clusterStat; + } + private GroupStatus getGroupStatus(Map<String, Group> groups) { GroupStatus status = null; boolean groupActive = true; http://git-wip-us.apache.org/repos/asf/stratos/blob/f0ba4beb/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusApplicationActivatedEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusApplicationActivatedEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusApplicationActivatedEvent.java deleted file mode 100644 index f04ae02..0000000 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusApplicationActivatedEvent.java +++ /dev/null @@ -1,38 +0,0 @@ -/* - * 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. - */ -package org.apache.stratos.messaging.event.application.status; - -import java.io.Serializable; - -/** - * This event will be fired upon the application activated is detected. - */ -public class AppStatusApplicationActivatedEvent extends StatusEvent implements Serializable { - private static final long serialVersionUID = 2625412714611885089L; - - private String appId; - - public AppStatusApplicationActivatedEvent(String appId) { - this.appId = appId; - } - - public String getAppId() { - return appId; - } -} http://git-wip-us.apache.org/repos/asf/stratos/blob/f0ba4beb/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusApplicationCreatedEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusApplicationCreatedEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusApplicationCreatedEvent.java deleted file mode 100644 index c432e14..0000000 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusApplicationCreatedEvent.java +++ /dev/null @@ -1,38 +0,0 @@ -/* - * 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. - */ -package org.apache.stratos.messaging.event.application.status; - -import java.io.Serializable; - -/** - * This event will be fired upon the application created is detected. - */ -public class AppStatusApplicationCreatedEvent extends StatusEvent implements Serializable { - private static final long serialVersionUID = 2625412714611885089L; - - private String appId; - - public AppStatusApplicationCreatedEvent(String appId) { - this.appId = appId; - } - - public String getAppId() { - return appId; - } -} http://git-wip-us.apache.org/repos/asf/stratos/blob/f0ba4beb/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusApplicationInactivatedEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusApplicationInactivatedEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusApplicationInactivatedEvent.java deleted file mode 100644 index f00a97a..0000000 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusApplicationInactivatedEvent.java +++ /dev/null @@ -1,38 +0,0 @@ -/* - * 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. - */ -package org.apache.stratos.messaging.event.application.status; - -import java.io.Serializable; - -/** - * This event will be fired upon the application inactivated is detected. - */ -public class AppStatusApplicationInactivatedEvent extends StatusEvent implements Serializable { - private static final long serialVersionUID = 2625412714611885089L; - - private String appId; - - public AppStatusApplicationInactivatedEvent(String appId) { - this.appId = appId; - } - - public String getAppId() { - return appId; - } -} http://git-wip-us.apache.org/repos/asf/stratos/blob/f0ba4beb/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusApplicationTerminatedEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusApplicationTerminatedEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusApplicationTerminatedEvent.java deleted file mode 100644 index 2dafcdc..0000000 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusApplicationTerminatedEvent.java +++ /dev/null @@ -1,47 +0,0 @@ -/* - * 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. - */ -package org.apache.stratos.messaging.event.application.status; - -import org.apache.stratos.messaging.domain.applications.ClusterDataHolder; - -import java.io.Serializable; -import java.util.Set; - -/** - * This event will be fired upon the application terminated is detected. - */ -public class AppStatusApplicationTerminatedEvent extends StatusEvent implements Serializable { - private static final long serialVersionUID = 2625412714611885089L; - - private String appId; - private Set<ClusterDataHolder> clusterData; - - public AppStatusApplicationTerminatedEvent(String appId, Set<ClusterDataHolder> clusterData) { - this.appId = appId; - this.clusterData = clusterData; - } - - public String getAppId() { - return appId; - } - - public Set<ClusterDataHolder> getClusterData() { - return clusterData; - } -} http://git-wip-us.apache.org/repos/asf/stratos/blob/f0ba4beb/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusApplicationTerminatingEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusApplicationTerminatingEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusApplicationTerminatingEvent.java deleted file mode 100644 index e2a3a09..0000000 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusApplicationTerminatingEvent.java +++ /dev/null @@ -1,38 +0,0 @@ -/* - * 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. - */ -package org.apache.stratos.messaging.event.application.status; - -import java.io.Serializable; - -/** - * This event will be fired upon the application terminating is detected. - */ -public class AppStatusApplicationTerminatingEvent extends StatusEvent implements Serializable { - private static final long serialVersionUID = 2625412714611885089L; - - private String appId; - - public AppStatusApplicationTerminatingEvent(String appId) { - this.appId = appId; - } - - public String getAppId() { - return appId; - } -} http://git-wip-us.apache.org/repos/asf/stratos/blob/f0ba4beb/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusClusterActivatedEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusClusterActivatedEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusClusterActivatedEvent.java deleted file mode 100644 index c5737c6..0000000 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusClusterActivatedEvent.java +++ /dev/null @@ -1,50 +0,0 @@ -/* - * 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. - */ - -package org.apache.stratos.messaging.event.application.status; - -/** - * This event is fired by cartridge agent when it has started the server and - * applications are ready to serve the incoming requests. - */ -public class AppStatusClusterActivatedEvent extends StatusEvent { - private static final long serialVersionUID = 2625412714611885089L; - - private final String serviceName; - private final String clusterId; - private String appId; - - public AppStatusClusterActivatedEvent(String appId, String serviceName, String clusterId) { - this.serviceName = serviceName; - this.clusterId = clusterId; - this.appId = appId; - } - - public String getServiceName() { - return serviceName; - } - - public String getClusterId() { - return clusterId; - } - - public String getAppId() { - return appId; - } -} http://git-wip-us.apache.org/repos/asf/stratos/blob/f0ba4beb/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusClusterCreatedEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusClusterCreatedEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusClusterCreatedEvent.java deleted file mode 100644 index 6480af2..0000000 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusClusterCreatedEvent.java +++ /dev/null @@ -1,50 +0,0 @@ -/* - * 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. - */ - -package org.apache.stratos.messaging.event.application.status; - -/** - * This event is fired by cartridge agent when it has started the server and - * applications are ready to serve the incoming requests. - */ -public class AppStatusClusterCreatedEvent extends StatusEvent { - private static final long serialVersionUID = 2625412714611885089L; - - private final String serviceName; - private final String clusterId; - private String appId; - - public AppStatusClusterCreatedEvent(String appId, String serviceName, String clusterId) { - this.serviceName = serviceName; - this.clusterId = clusterId; - this.appId = appId; - } - - public String getServiceName() { - return serviceName; - } - - public String getClusterId() { - return clusterId; - } - - public String getAppId() { - return appId; - } -} http://git-wip-us.apache.org/repos/asf/stratos/blob/f0ba4beb/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusClusterInactivateEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusClusterInactivateEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusClusterInactivateEvent.java deleted file mode 100644 index 6d8ed46..0000000 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusClusterInactivateEvent.java +++ /dev/null @@ -1,50 +0,0 @@ -/* - * 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. - */ - -package org.apache.stratos.messaging.event.application.status; - -/** - * This event is fired by cartridge agent when it has started the server and - * applications are ready to serve the incoming requests. - */ -public class AppStatusClusterInactivateEvent extends StatusEvent { - private static final long serialVersionUID = 2625412714611885089L; - - private final String serviceName; - private final String clusterId; - private String appId; - - public AppStatusClusterInactivateEvent(String appId, String serviceName, String clusterId) { - this.serviceName = serviceName; - this.clusterId = clusterId; - this.appId = appId; - } - - public String getServiceName() { - return serviceName; - } - - public String getClusterId() { - return clusterId; - } - - public String getAppId() { - return appId; - } -} http://git-wip-us.apache.org/repos/asf/stratos/blob/f0ba4beb/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusClusterMaintenanceModeEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusClusterMaintenanceModeEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusClusterMaintenanceModeEvent.java deleted file mode 100644 index 527d86e..0000000 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusClusterMaintenanceModeEvent.java +++ /dev/null @@ -1,49 +0,0 @@ -/* - * 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. - */ -package org.apache.stratos.messaging.event.application.status; - -import java.io.Serializable; - -/** - * This will be fired upon the cluster instability detection by either cep/autoscaler. - */ -public class AppStatusClusterMaintenanceModeEvent extends StatusEvent implements Serializable { - private final String serviceName; - private final String clusterId; - private String appId; - - public AppStatusClusterMaintenanceModeEvent(String appId, String serviceName, String clusterId) { - this.serviceName = serviceName; - this.clusterId = clusterId; - this.appId = appId; - } - - public String getServiceName() { - return serviceName; - } - - public String getClusterId() { - return clusterId; - } - - - public String getAppId() { - return appId; - } -} http://git-wip-us.apache.org/repos/asf/stratos/blob/f0ba4beb/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusClusterReadyToShutdownEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusClusterReadyToShutdownEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusClusterReadyToShutdownEvent.java deleted file mode 100644 index 7841d9c..0000000 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusClusterReadyToShutdownEvent.java +++ /dev/null @@ -1,47 +0,0 @@ -/* - * 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. - */ -package org.apache.stratos.messaging.event.application.status; - -/** - * This event is fired by autoscaler before actually terminate a cluster. - */ -public class AppStatusClusterReadyToShutdownEvent extends StatusEvent { - private final String serviceName; - private final String clusterId; - private String appId; - - public AppStatusClusterReadyToShutdownEvent(String appId, String serviceName, String clusterId) { - this.serviceName = serviceName; - this.clusterId = clusterId; - this.appId = appId; - } - - public String getServiceName() { - return serviceName; - } - - public String getClusterId() { - return clusterId; - } - - - public String getAppId() { - return appId; - } -} http://git-wip-us.apache.org/repos/asf/stratos/blob/f0ba4beb/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusClusterTerminatedEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusClusterTerminatedEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusClusterTerminatedEvent.java deleted file mode 100644 index 919d0ca..0000000 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusClusterTerminatedEvent.java +++ /dev/null @@ -1,50 +0,0 @@ -/* - * 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. - */ - -package org.apache.stratos.messaging.event.application.status; - -/** - * This event is fired by cartridge agent when it has started the server and - * applications are ready to serve the incoming requests. - */ -public class AppStatusClusterTerminatedEvent extends StatusEvent { - private static final long serialVersionUID = 2625412714611885089L; - - private final String serviceName; - private final String clusterId; - private String appId; - - public AppStatusClusterTerminatedEvent(String appId, String serviceName, String clusterId) { - this.serviceName = serviceName; - this.clusterId = clusterId; - this.appId = appId; - } - - public String getServiceName() { - return serviceName; - } - - public String getClusterId() { - return clusterId; - } - - public String getAppId() { - return appId; - } -} http://git-wip-us.apache.org/repos/asf/stratos/blob/f0ba4beb/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusClusterTerminatingEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusClusterTerminatingEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusClusterTerminatingEvent.java deleted file mode 100644 index 7a6baf0..0000000 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusClusterTerminatingEvent.java +++ /dev/null @@ -1,50 +0,0 @@ -/* - * 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. - */ - -package org.apache.stratos.messaging.event.application.status; - -/** - * This event is fired by cartridge agent when it has started the server and - * applications are ready to serve the incoming requests. - */ -public class AppStatusClusterTerminatingEvent extends StatusEvent { - private static final long serialVersionUID = 2625412714611885089L; - - private final String serviceName; - private final String clusterId; - private String appId; - - public AppStatusClusterTerminatingEvent(String appId, String serviceName, String clusterId) { - this.serviceName = serviceName; - this.clusterId = clusterId; - this.appId = appId; - } - - public String getServiceName() { - return serviceName; - } - - public String getClusterId() { - return clusterId; - } - - public String getAppId() { - return appId; - } -} http://git-wip-us.apache.org/repos/asf/stratos/blob/f0ba4beb/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusGroupActivatedEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusGroupActivatedEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusGroupActivatedEvent.java deleted file mode 100644 index 3da8667..0000000 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusGroupActivatedEvent.java +++ /dev/null @@ -1,44 +0,0 @@ -/* - * 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. - */ - -package org.apache.stratos.messaging.event.application.status; - -/** - * This event is fired by cartridge agent when it has started the server and - * applications are ready to serve the incoming requests. - */ -public class AppStatusGroupActivatedEvent extends StatusEvent { - private static final long serialVersionUID = 2625412714611885089L; - - private String groupId; - private String appId; - - public AppStatusGroupActivatedEvent(String appId, String groupId) { - this.appId = appId; - this.groupId = groupId; - } - - public String getGroupId() { - return this.groupId; - } - - public String getAppId() { - return appId; - } -} http://git-wip-us.apache.org/repos/asf/stratos/blob/f0ba4beb/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusGroupCreatedEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusGroupCreatedEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusGroupCreatedEvent.java deleted file mode 100644 index 04ee30e..0000000 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusGroupCreatedEvent.java +++ /dev/null @@ -1,44 +0,0 @@ -/* - * 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. - */ - -package org.apache.stratos.messaging.event.application.status; - -/** - * This event is fired by cartridge agent when it has started the server and - * applications are ready to serve the incoming requests. - */ -public class AppStatusGroupCreatedEvent extends StatusEvent { - private static final long serialVersionUID = 2625412714611885089L; - - private String groupId; - private String appId; - - public AppStatusGroupCreatedEvent(String appId, String groupId) { - this.appId = appId; - this.groupId = groupId; - } - - public String getGroupId() { - return this.groupId; - } - - public String getAppId() { - return appId; - } -} http://git-wip-us.apache.org/repos/asf/stratos/blob/f0ba4beb/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusGroupInactivateEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusGroupInactivateEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusGroupInactivateEvent.java deleted file mode 100644 index ee26292..0000000 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusGroupInactivateEvent.java +++ /dev/null @@ -1,44 +0,0 @@ -/* - * 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. - */ - -package org.apache.stratos.messaging.event.application.status; - -/** - * This event is fired by cartridge agent when it has started the server and - * applications are ready to serve the incoming requests. - */ -public class AppStatusGroupInactivateEvent extends StatusEvent { - private static final long serialVersionUID = 2625412714611885089L; - - private String groupId; - private String appId; - - public AppStatusGroupInactivateEvent(String appId, String groupId) { - this.appId = appId; - this.groupId = groupId; - } - - public String getGroupId() { - return this.groupId; - } - - public String getAppId() { - return appId; - } -} http://git-wip-us.apache.org/repos/asf/stratos/blob/f0ba4beb/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusGroupMaintenanceModeEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusGroupMaintenanceModeEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusGroupMaintenanceModeEvent.java deleted file mode 100644 index a1a787c..0000000 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusGroupMaintenanceModeEvent.java +++ /dev/null @@ -1,41 +0,0 @@ -/* - * 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. - */ -package org.apache.stratos.messaging.event.application.status; - -/** - * This event will be fired upon the instability of group detection by autoscaler. - */ -public class AppStatusGroupMaintenanceModeEvent extends StatusEvent { - private String groupId; - private String appId; - - public AppStatusGroupMaintenanceModeEvent(String appId, String groupId) { - this.appId = appId; - this.groupId = groupId; - } - - public String getGroupId(String groupId) { - return this.groupId; - } - - public String getAppId() { - return appId; - } - -} http://git-wip-us.apache.org/repos/asf/stratos/blob/f0ba4beb/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusGroupReadyToShutdownEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusGroupReadyToShutdownEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusGroupReadyToShutdownEvent.java deleted file mode 100644 index eaba17d..0000000 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusGroupReadyToShutdownEvent.java +++ /dev/null @@ -1,40 +0,0 @@ -/* - * 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. - */ -package org.apache.stratos.messaging.event.application.status; - -/** - * This event is fired by autoscaler before actually terminate a group. - */ -public class AppStatusGroupReadyToShutdownEvent extends StatusEvent { - private String groupId; - private String appId; - - public AppStatusGroupReadyToShutdownEvent(String appId, String groupId) { - this.appId = appId; - this.groupId = groupId; - } - - public String getGroupId(String groupId) { - return this.groupId; - } - - public String getAppId() { - return appId; - } -} http://git-wip-us.apache.org/repos/asf/stratos/blob/f0ba4beb/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusGroupTerminatedEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusGroupTerminatedEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusGroupTerminatedEvent.java deleted file mode 100644 index db31b64..0000000 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusGroupTerminatedEvent.java +++ /dev/null @@ -1,44 +0,0 @@ -/* - * 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. - */ - -package org.apache.stratos.messaging.event.application.status; - -/** - * This event is fired by cartridge agent when it has started the server and - * applications are ready to serve the incoming requests. - */ -public class AppStatusGroupTerminatedEvent extends StatusEvent { - private static final long serialVersionUID = 2625412714611885089L; - - private String groupId; - private String appId; - - public AppStatusGroupTerminatedEvent(String appId, String groupId) { - this.appId = appId; - this.groupId = groupId; - } - - public String getGroupId() { - return this.groupId; - } - - public String getAppId() { - return appId; - } -} http://git-wip-us.apache.org/repos/asf/stratos/blob/f0ba4beb/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusGroupTerminatingEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusGroupTerminatingEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusGroupTerminatingEvent.java deleted file mode 100644 index 52db5fb..0000000 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/AppStatusGroupTerminatingEvent.java +++ /dev/null @@ -1,44 +0,0 @@ -/* - * 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. - */ - -package org.apache.stratos.messaging.event.application.status; - -/** - * This event is fired by cartridge agent when it has started the server and - * applications are ready to serve the incoming requests. - */ -public class AppStatusGroupTerminatingEvent extends StatusEvent { - private static final long serialVersionUID = 2625412714611885089L; - - private String groupId; - private String appId; - - public AppStatusGroupTerminatingEvent(String appId, String groupId) { - this.appId = appId; - this.groupId = groupId; - } - - public String getGroupId() { - return this.groupId; - } - - public String getAppId() { - return appId; - } -} http://git-wip-us.apache.org/repos/asf/stratos/blob/f0ba4beb/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/StatusEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/StatusEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/StatusEvent.java deleted file mode 100644 index 7ffc449..0000000 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/application/status/StatusEvent.java +++ /dev/null @@ -1,31 +0,0 @@ -/* - * 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. - */ - -package org.apache.stratos.messaging.event.application.status; - -import org.apache.stratos.messaging.event.Event; - -import java.io.Serializable; - -/** - * Represents all instance status events. - */ -public abstract class StatusEvent extends Event implements Serializable { - private static final long serialVersionUID = -4790128084271867615L; -} http://git-wip-us.apache.org/repos/asf/stratos/blob/f0ba4beb/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/applications/AppClusterActivatedEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/applications/AppClusterActivatedEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/applications/AppClusterActivatedEvent.java new file mode 100644 index 0000000..688b382 --- /dev/null +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/applications/AppClusterActivatedEvent.java @@ -0,0 +1,50 @@ +/* + * 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. + */ + +package org.apache.stratos.messaging.event.applications; + +/** + * This event is fired by cartridge agent when it has started the server and + * applications are ready to serve the incoming requests. + */ +public class AppClusterActivatedEvent extends StatusEvent { + private static final long serialVersionUID = 2625412714611885089L; + + private final String serviceName; + private final String clusterId; + private String appId; + + public AppClusterActivatedEvent(String appId, String serviceName, String clusterId) { + this.serviceName = serviceName; + this.clusterId = clusterId; + this.appId = appId; + } + + public String getServiceName() { + return serviceName; + } + + public String getClusterId() { + return clusterId; + } + + public String getAppId() { + return appId; + } +} http://git-wip-us.apache.org/repos/asf/stratos/blob/f0ba4beb/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/applications/AppClusterCreatedEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/applications/AppClusterCreatedEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/applications/AppClusterCreatedEvent.java new file mode 100644 index 0000000..3382a34 --- /dev/null +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/applications/AppClusterCreatedEvent.java @@ -0,0 +1,50 @@ +/* + * 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. + */ + +package org.apache.stratos.messaging.event.applications; + +/** + * This event is fired by cartridge agent when it has started the server and + * applications are ready to serve the incoming requests. + */ +public class AppClusterCreatedEvent extends StatusEvent { + private static final long serialVersionUID = 2625412714611885089L; + + private final String serviceName; + private final String clusterId; + private String appId; + + public AppClusterCreatedEvent(String appId, String serviceName, String clusterId) { + this.serviceName = serviceName; + this.clusterId = clusterId; + this.appId = appId; + } + + public String getServiceName() { + return serviceName; + } + + public String getClusterId() { + return clusterId; + } + + public String getAppId() { + return appId; + } +} http://git-wip-us.apache.org/repos/asf/stratos/blob/f0ba4beb/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/applications/AppClusterInactivateEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/applications/AppClusterInactivateEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/applications/AppClusterInactivateEvent.java new file mode 100644 index 0000000..bf8926e --- /dev/null +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/applications/AppClusterInactivateEvent.java @@ -0,0 +1,50 @@ +/* + * 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. + */ + +package org.apache.stratos.messaging.event.applications; + +/** + * This event is fired by cartridge agent when it has started the server and + * applications are ready to serve the incoming requests. + */ +public class AppClusterInactivateEvent extends StatusEvent { + private static final long serialVersionUID = 2625412714611885089L; + + private final String serviceName; + private final String clusterId; + private String appId; + + public AppClusterInactivateEvent(String appId, String serviceName, String clusterId) { + this.serviceName = serviceName; + this.clusterId = clusterId; + this.appId = appId; + } + + public String getServiceName() { + return serviceName; + } + + public String getClusterId() { + return clusterId; + } + + public String getAppId() { + return appId; + } +} http://git-wip-us.apache.org/repos/asf/stratos/blob/f0ba4beb/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/applications/AppClusterTerminatedEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/applications/AppClusterTerminatedEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/applications/AppClusterTerminatedEvent.java new file mode 100644 index 0000000..d269d38 --- /dev/null +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/applications/AppClusterTerminatedEvent.java @@ -0,0 +1,50 @@ +/* + * 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. + */ + +package org.apache.stratos.messaging.event.applications; + +/** + * This event is fired by cartridge agent when it has started the server and + * applications are ready to serve the incoming requests. + */ +public class AppClusterTerminatedEvent extends StatusEvent { + private static final long serialVersionUID = 2625412714611885089L; + + private final String serviceName; + private final String clusterId; + private String appId; + + public AppClusterTerminatedEvent(String appId, String serviceName, String clusterId) { + this.serviceName = serviceName; + this.clusterId = clusterId; + this.appId = appId; + } + + public String getServiceName() { + return serviceName; + } + + public String getClusterId() { + return clusterId; + } + + public String getAppId() { + return appId; + } +} http://git-wip-us.apache.org/repos/asf/stratos/blob/f0ba4beb/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/applications/AppClusterTerminatingEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/applications/AppClusterTerminatingEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/applications/AppClusterTerminatingEvent.java new file mode 100644 index 0000000..547a681 --- /dev/null +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/applications/AppClusterTerminatingEvent.java @@ -0,0 +1,50 @@ +/* + * 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. + */ + +package org.apache.stratos.messaging.event.applications; + +/** + * This event is fired by cartridge agent when it has started the server and + * applications are ready to serve the incoming requests. + */ +public class AppClusterTerminatingEvent extends StatusEvent { + private static final long serialVersionUID = 2625412714611885089L; + + private final String serviceName; + private final String clusterId; + private String appId; + + public AppClusterTerminatingEvent(String appId, String serviceName, String clusterId) { + this.serviceName = serviceName; + this.clusterId = clusterId; + this.appId = appId; + } + + public String getServiceName() { + return serviceName; + } + + public String getClusterId() { + return clusterId; + } + + public String getAppId() { + return appId; + } +} http://git-wip-us.apache.org/repos/asf/stratos/blob/f0ba4beb/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/applications/AppStatusGroupInactivateEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/applications/AppStatusGroupInactivateEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/applications/AppStatusGroupInactivateEvent.java new file mode 100644 index 0000000..6eeb2dc --- /dev/null +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/applications/AppStatusGroupInactivateEvent.java @@ -0,0 +1,44 @@ +/* + * 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. + */ + +package org.apache.stratos.messaging.event.applications; + +/** + * This event is fired by cartridge agent when it has started the server and + * applications are ready to serve the incoming requests. + */ +public class AppStatusGroupInactivateEvent extends StatusEvent { + private static final long serialVersionUID = 2625412714611885089L; + + private String groupId; + private String appId; + + public AppStatusGroupInactivateEvent(String appId, String groupId) { + this.appId = appId; + this.groupId = groupId; + } + + public String getGroupId() { + return this.groupId; + } + + public String getAppId() { + return appId; + } +} http://git-wip-us.apache.org/repos/asf/stratos/blob/f0ba4beb/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/applications/ApplicationActivatedEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/applications/ApplicationActivatedEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/applications/ApplicationActivatedEvent.java new file mode 100644 index 0000000..7e6a8b4 --- /dev/null +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/applications/ApplicationActivatedEvent.java @@ -0,0 +1,38 @@ +/* + * 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. + */ +package org.apache.stratos.messaging.event.applications; + +import java.io.Serializable; + +/** + * This event will be fired upon the application activated is detected. + */ +public class ApplicationActivatedEvent extends StatusEvent implements Serializable { + private static final long serialVersionUID = 2625412714611885089L; + + private String appId; + + public ApplicationActivatedEvent(String appId) { + this.appId = appId; + } + + public String getAppId() { + return appId; + } +} http://git-wip-us.apache.org/repos/asf/stratos/blob/f0ba4beb/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/applications/ApplicationCreatedEvent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/applications/ApplicationCreatedEvent.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/applications/ApplicationCreatedEvent.java new file mode 100644 index 0000000..5d220fa --- /dev/null +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/event/applications/ApplicationCreatedEvent.java @@ -0,0 +1,38 @@ +/* + * 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. + */ +package org.apache.stratos.messaging.event.applications; + +import java.io.Serializable; + +/** + * This event will be fired upon the application created is detected. + */ +public class ApplicationCreatedEvent extends StatusEvent implements Serializable { + private static final long serialVersionUID = 2625412714611885089L; + + private String appId; + + public ApplicationCreatedEvent(String appId) { + this.appId = appId; + } + + public String getAppId() { + return appId; + } +}
