Class DefaultSchedulerService
- java.lang.Object
-
- org.pentaho.platform.scheduler2.ws.DefaultSchedulerService
-
- All Implemented Interfaces:
ISchedulerService
public class DefaultSchedulerService extends Object implements ISchedulerService
The default implementation of theISchedulerService
which acts as a proxy to theIScheduler
- Author:
- aphillips
-
-
Constructor Summary
Constructors Constructor Description DefaultSchedulerService()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description String
createComplexJob(String jobName, Map<String,ParamValue> jobParams, ComplexJobTrigger trigger)
String
createSimpleJob(String jobName, Map<String,ParamValue> jobParams, SimpleJobTrigger trigger)
Job[]
getJobs()
int
getSchedulerStatus()
Returns the scheduler status.void
pause()
void
pauseJob(String jobId)
void
removeJob(String jobId)
void
resumeJob(String jobId)
void
setDefaultActionId(String defaultActionId)
void
start()
void
updateJobToUseComplexTrigger(String jobId, Map<String,ParamValue> jobParams, ComplexJobTrigger trigger)
void
updateJobToUseSimpleTrigger(String jobId, Map<String,ParamValue> jobParams, SimpleJobTrigger trigger)
-
-
-
Method Detail
-
setDefaultActionId
public void setDefaultActionId(String defaultActionId)
-
createSimpleJob
public String createSimpleJob(String jobName, Map<String,ParamValue> jobParams, SimpleJobTrigger trigger) throws SchedulerException
- Specified by:
createSimpleJob
in interfaceISchedulerService
- Throws:
SchedulerException
- See Also:
IScheduler#createJob(String, Class, java.util.Map, org.pentaho.platform.api.scheduler2.JobTrigger)
-
createComplexJob
public String createComplexJob(String jobName, Map<String,ParamValue> jobParams, ComplexJobTrigger trigger) throws SchedulerException
- Specified by:
createComplexJob
in interfaceISchedulerService
- Throws:
SchedulerException
- See Also:
IScheduler#createJob(String, Class, java.util.Map, org.pentaho.platform.api.scheduler2.JobTrigger)
-
getJobs
public Job[] getJobs() throws SchedulerException
- Specified by:
getJobs
in interfaceISchedulerService
- Throws:
SchedulerException
- See Also:
IScheduler#getJobs(org.pentaho.platform.api.scheduler2.IJobFilter)
-
pause
public void pause() throws SchedulerException
- Specified by:
pause
in interfaceISchedulerService
- Throws:
SchedulerException
- See Also:
IScheduler#pause()
-
pauseJob
public void pauseJob(String jobId) throws SchedulerException
- Specified by:
pauseJob
in interfaceISchedulerService
- Throws:
SchedulerException
- See Also:
IScheduler#pauseJob(String)
-
removeJob
public void removeJob(String jobId) throws SchedulerException
- Specified by:
removeJob
in interfaceISchedulerService
- Throws:
SchedulerException
- See Also:
IScheduler#removeJob(String)
-
start
public void start() throws SchedulerException
- Specified by:
start
in interfaceISchedulerService
- Throws:
SchedulerException
- See Also:
IScheduler#start()
-
resumeJob
public void resumeJob(String jobId) throws SchedulerException
- Specified by:
resumeJob
in interfaceISchedulerService
- Throws:
SchedulerException
- See Also:
IScheduler#resumeJob(String)
-
getSchedulerStatus
public int getSchedulerStatus() throws SchedulerException
Returns the scheduler status.- Specified by:
getSchedulerStatus
in interfaceISchedulerService
- Returns:
- the ordinal value of the current scheduler state
- Throws:
SchedulerException
- See Also:
IScheduler#getStatus()
-
updateJobToUseSimpleTrigger
public void updateJobToUseSimpleTrigger(String jobId, Map<String,ParamValue> jobParams, SimpleJobTrigger trigger) throws SchedulerException
- Specified by:
updateJobToUseSimpleTrigger
in interfaceISchedulerService
- Throws:
SchedulerException
- See Also:
IScheduler#updateJob(String, java.util.Map, org.pentaho.platform.api.scheduler2.JobTrigger)
-
updateJobToUseComplexTrigger
public void updateJobToUseComplexTrigger(String jobId, Map<String,ParamValue> jobParams, ComplexJobTrigger trigger) throws SchedulerException
- Specified by:
updateJobToUseComplexTrigger
in interfaceISchedulerService
- Throws:
SchedulerException
- See Also:
IScheduler#updateJob(String, java.util.Map, org.pentaho.platform.api.scheduler2.JobTrigger)
-
-