12:04 p.m.
Author: nfilotto
Date: 2011-05-19 13:04:04 -0400 (Thu, 19 May 2011)
New Revision: 4398
Modified:
kernel/trunk/exo.kernel.component.common/src/main/java/org/exoplatform/services/scheduler/JobSchedulerService.java
kernel/trunk/exo.kernel.component.common/src/main/java/org/exoplatform/services/scheduler/impl/JobSchedulerServiceImpl.java
Log:
EXOJCR-1355: Allow to suspend and resume the JobSchedulerService thanks to JMX and/or
Rest
Modified:
kernel/trunk/exo.kernel.component.common/src/main/java/org/exoplatform/services/scheduler/JobSchedulerService.java
===================================================================
---
kernel/trunk/exo.kernel.component.common/src/main/java/org/exoplatform/services/scheduler/JobSchedulerService.java 2011-05-19
12:05:52 UTC (rev 4397)
+++
kernel/trunk/exo.kernel.component.common/src/main/java/org/exoplatform/services/scheduler/JobSchedulerService.java 2011-05-19
17:04:04 UTC (rev 4398)
@@ -19,6 +19,10 @@
package org.exoplatform.services.scheduler;
import org.exoplatform.container.component.ComponentPlugin;
+import org.exoplatform.management.annotations.Managed;
+import org.exoplatform.management.jmx.annotations.NameTemplate;
+import org.exoplatform.management.jmx.annotations.Property;
+import org.exoplatform.management.rest.annotations.RESTEndpoint;
import org.quartz.JobDataMap;
import org.quartz.JobDetail;
import org.quartz.JobListener;
@@ -32,6 +36,9 @@
* Created by The eXo Platform SAS Author : Hoa Pham hoapham(a)exoplatform.com Oct
* 5, 2005
*/
+@Managed
+@NameTemplate(@Property(key = "service", value =
"JobSchedulerService"))
+@RESTEndpoint(path = "JobSchedulerService")
public interface JobSchedulerService
{
public void addJob(JobInfo jinfo, Date date) throws Exception;
@@ -101,4 +108,16 @@
public Date rescheduleJob(String triggerName, String groupName, Trigger newTrigger)
throws Exception;
public JobDetail getJob(JobInfo jobInfo) throws Exception;
+
+ /**
+ * Suspends all the registered jobs
+ * @return <code>true</code> if the jobs could be suspended,
<code>false</code> otherwise
+ */
+ public boolean suspend();
+
+ /**
+ * Resumes all the registered jobs
+ * @return <code>true</code> if the jobs could be resumed,
<code>false</code> otherwise
+ */
+ public boolean resume();
}
Modified:
kernel/trunk/exo.kernel.component.common/src/main/java/org/exoplatform/services/scheduler/impl/JobSchedulerServiceImpl.java
===================================================================
---
kernel/trunk/exo.kernel.component.common/src/main/java/org/exoplatform/services/scheduler/impl/JobSchedulerServiceImpl.java 2011-05-19
12:05:52 UTC (rev 4397)
+++
kernel/trunk/exo.kernel.component.common/src/main/java/org/exoplatform/services/scheduler/impl/JobSchedulerServiceImpl.java 2011-05-19
17:04:04 UTC (rev 4398)
@@ -20,6 +20,8 @@
import org.exoplatform.container.component.ComponentPlugin;
import org.exoplatform.container.xml.PortalContainerInfo;
+import org.exoplatform.management.annotations.Managed;
+import org.exoplatform.management.annotations.ManagedDescription;
import org.exoplatform.services.log.ExoLogger;
import org.exoplatform.services.log.Log;
import org.exoplatform.services.scheduler.CronJob;
@@ -394,6 +396,38 @@
return scheduler_.rescheduleJob(triggerName, groupName, newTrigger);
}
+ @Managed
+ @ManagedDescription("Suspend all the existing jobs")
+ public boolean suspend()
+ {
+ try
+ {
+ scheduler_.standby();
+ return true;
+ }
+ catch (SchedulerException e)
+ {
+ log.error("Could not suspend the scheduler", e);
+ }
+ return false;
+ }
+
+ @Managed
+ @ManagedDescription("Resume all the existing jobs")
+ public boolean resume()
+ {
+ try
+ {
+ scheduler_.start();
+ return true;
+ }
+ catch (SchedulerException e)
+ {
+ log.error("Could not resume the scheduler", e);
+ }
+ return false;
+ }
+
public void start()
{
try