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/docker-grouping-merge Commit: ff2e971d6dfad83fbc29d5d5380bf3af6fe4d98c Parents: 226b870 Author: Isuru Haththotuwa <[email protected]> Authored: Fri Oct 31 16:21:22 2014 +0530 Committer: Isuru Haththotuwa <[email protected]> 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 {
