You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@stratos.apache.org by is...@apache.org on 2014/10/31 11:51:41 UTC
git commit: ApplicationSynchronizerTask initial impl.
Repository: stratos
Updated Branches:
refs/heads/4.0.0-grouping 226b8709e -> ff2e971d6
ApplicationSynchronizerTask initial impl.
Project: http://git-wip-us.apache.org/repos/asf/stratos/repo
Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/ff2e971d
Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/ff2e971d
Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/ff2e971d
Branch: refs/heads/4.0.0-grouping
Commit: ff2e971d6dfad83fbc29d5d5380bf3af6fe4d98c
Parents: 226b870
Author: Isuru Haththotuwa <is...@apache.org>
Authored: Fri Oct 31 16:21:22 2014 +0530
Committer: Isuru Haththotuwa <is...@apache.org>
Committed: Fri Oct 31 16:21:22 2014 +0530
----------------------------------------------------------------------
.../applications/ApplicationSynchronizerTask.java | 9 ++++++++-
.../applications/topic/ApplicationsEventPublisher.java | 4 ++++
2 files changed, 12 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/stratos/blob/ff2e971d/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/applications/ApplicationSynchronizerTask.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/applications/ApplicationSynchronizerTask.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/applications/ApplicationSynchronizerTask.java
index 571e7a8..a8ce042 100644
--- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/applications/ApplicationSynchronizerTask.java
+++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/applications/ApplicationSynchronizerTask.java
@@ -19,6 +19,9 @@
package org.apache.stratos.autoscaler.applications;
+import org.apache.stratos.autoscaler.applications.topic.ApplicationsEventPublisher;
+import org.apache.stratos.messaging.domain.applications.Applications;
+import org.apache.stratos.messaging.message.receiver.applications.ApplicationManager;
import org.wso2.carbon.ntask.core.Task;
import java.util.Map;
@@ -38,6 +41,10 @@ public class ApplicationSynchronizerTask implements Task {
@Override
public void execute() {
-
+ Applications applications = ApplicationManager.getApplications();
+ if (applications != null) {
+ // publish complete Applications event
+ ApplicationsEventPublisher.sendCompleteApplicationsEvent(applications);
+ }
}
}
http://git-wip-us.apache.org/repos/asf/stratos/blob/ff2e971d/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/applications/topic/ApplicationsEventPublisher.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/applications/topic/ApplicationsEventPublisher.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/applications/topic/ApplicationsEventPublisher.java
index bdbffc0..0a0b261 100644
--- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/applications/topic/ApplicationsEventPublisher.java
+++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/applications/topic/ApplicationsEventPublisher.java
@@ -18,6 +18,10 @@ import java.util.Set;
public class ApplicationsEventPublisher {
private static final Log log = LogFactory.getLog(ApplicationsEventPublisher.class);
+ public static void sendCompleteApplicationsEvent (Applications completeApplications) {
+
+ publishEvent(new CompleteApplicationsEvent(completeApplications));
+ }
public static void sendGroupCreatedEvent(String appId, String groupId) {
try {