com.liferay.portal.scheduler.quartz
Class QuartzSchedulerEngine
java.lang.Object
com.liferay.portal.scheduler.quartz.QuartzSchedulerEngine
- All Implemented Interfaces:
- SchedulerEngine
public class QuartzSchedulerEngine
- extends Object
- implements SchedulerEngine
| Fields inherited from interface com.liferay.portal.kernel.scheduler.SchedulerEngine |
CONTEXT_PATH, DESCRIPTION, DESCRIPTION_MAX_LENGTH, DESTINATION_NAME, DISABLE, END_TIME, EXCEPTIONS_MAX_SIZE, FINAL_FIRE_TIME, GROUP_NAME_MAX_LENGTH, JOB_NAME_MAX_LENGTH, JOB_STATE, LANGUAGE, MESSAGE, MESSAGE_LISTENER_UUID, NEXT_FIRE_TIME, PREVIOUS_FIRE_TIME, RECEIVER_KEY, SCRIPT, START_TIME, STORAGE_TYPE |
|
Method Summary |
void |
afterPropertiesSet()
|
protected void |
delete(org.quartz.Scheduler scheduler,
String groupName)
|
protected void |
delete(org.quartz.Scheduler scheduler,
String jobName,
String groupName)
|
void |
delete(String groupName)
|
void |
delete(String jobName,
String groupName)
|
void |
destroy()
|
protected String |
fixMaxLength(String argument,
int maxLength)
|
protected String |
getFullName(String jobName,
String groupName)
|
protected JobState |
getJobState(org.quartz.JobDataMap jobDataMap)
|
protected Message |
getMessage(org.quartz.JobDataMap jobDataMap)
|
protected String |
getOriginalGroupName(String groupName)
|
protected org.quartz.Trigger |
getQuartzTrigger(Trigger trigger)
|
protected SchedulerResponse |
getScheduledJob(org.quartz.Scheduler scheduler,
String jobName,
String groupName)
|
SchedulerResponse |
getScheduledJob(String jobName,
String groupName)
|
List<SchedulerResponse> |
getScheduledJobs()
|
protected List<SchedulerResponse> |
getScheduledJobs(org.quartz.Scheduler scheduler,
String groupName)
|
List<SchedulerResponse> |
getScheduledJobs(String groupName)
|
protected org.quartz.Scheduler |
getScheduler(String groupName)
|
protected StorageType |
getStorageType(String groupName)
|
protected org.quartz.Scheduler |
initializeScheduler(String propertiesPrefix,
boolean useQuartzCluster)
|
protected void |
initJobState()
|
protected void |
pause(org.quartz.Scheduler scheduler,
String groupName)
|
protected void |
pause(org.quartz.Scheduler scheduler,
String jobName,
String groupName)
|
void |
pause(String groupName)
|
void |
pause(String jobName,
String groupName)
|
protected void |
resume(org.quartz.Scheduler scheduler,
String groupName)
|
protected void |
resume(org.quartz.Scheduler scheduler,
String jobName,
String groupName)
|
void |
resume(String groupName)
|
void |
resume(String jobName,
String groupName)
|
protected void |
schedule(org.quartz.Scheduler scheduler,
StorageType storageType,
org.quartz.Trigger trigger,
String description,
String destinationName,
Message message)
|
void |
schedule(Trigger trigger,
String description,
String destination,
Message message)
|
void |
shutdown()
|
void |
start()
|
void |
suppressError(String jobName,
String groupName)
|
protected void |
suppressError(String jobName,
String groupName,
org.quartz.Scheduler scheduler)
|
void |
unschedule(String groupName)
|
protected void |
unschedule(String groupName,
org.quartz.Scheduler scheduler)
|
void |
unschedule(String jobName,
String groupName)
|
protected void |
unschedule(String jobName,
String groupName,
org.quartz.Scheduler scheduler)
|
protected void |
update(org.quartz.Scheduler scheduler,
Trigger trigger)
|
void |
update(Trigger trigger)
|
protected void |
updateJobState(org.quartz.Scheduler scheduler,
String jobName,
String groupName,
TriggerState triggerState,
boolean suppressError)
|
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
quartzLocalService
@BeanReference(name="com.liferay.portal.service.QuartzLocalService")
protected QuartzLocalService quartzLocalService
QuartzSchedulerEngine
public QuartzSchedulerEngine()
afterPropertiesSet
public void afterPropertiesSet()
delete
public void delete(String groupName)
throws SchedulerException
- Specified by:
delete in interface SchedulerEngine
- Throws:
SchedulerException
delete
public void delete(String jobName,
String groupName)
throws SchedulerException
- Specified by:
delete in interface SchedulerEngine
- Throws:
SchedulerException
destroy
public void destroy()
getScheduledJob
public SchedulerResponse getScheduledJob(String jobName,
String groupName)
throws SchedulerException
- Specified by:
getScheduledJob in interface SchedulerEngine
- Throws:
SchedulerException
getScheduledJobs
public List<SchedulerResponse> getScheduledJobs()
throws SchedulerException
- Specified by:
getScheduledJobs in interface SchedulerEngine
- Throws:
SchedulerException
getScheduledJobs
public List<SchedulerResponse> getScheduledJobs(String groupName)
throws SchedulerException
- Specified by:
getScheduledJobs in interface SchedulerEngine
- Throws:
SchedulerException
pause
public void pause(String groupName)
throws SchedulerException
- Specified by:
pause in interface SchedulerEngine
- Throws:
SchedulerException
pause
public void pause(String jobName,
String groupName)
throws SchedulerException
- Specified by:
pause in interface SchedulerEngine
- Throws:
SchedulerException
resume
public void resume(String groupName)
throws SchedulerException
- Specified by:
resume in interface SchedulerEngine
- Throws:
SchedulerException
resume
public void resume(String jobName,
String groupName)
throws SchedulerException
- Specified by:
resume in interface SchedulerEngine
- Throws:
SchedulerException
schedule
public void schedule(Trigger trigger,
String description,
String destination,
Message message)
throws SchedulerException
- Specified by:
schedule in interface SchedulerEngine
- Throws:
SchedulerException
shutdown
public void shutdown()
throws SchedulerException
- Specified by:
shutdown in interface SchedulerEngine
- Throws:
SchedulerException
start
public void start()
throws SchedulerException
- Specified by:
start in interface SchedulerEngine
- Throws:
SchedulerException
suppressError
public void suppressError(String jobName,
String groupName)
throws SchedulerException
- Specified by:
suppressError in interface SchedulerEngine
- Throws:
SchedulerException
unschedule
public void unschedule(String groupName)
throws SchedulerException
- Specified by:
unschedule in interface SchedulerEngine
- Throws:
SchedulerException
unschedule
public void unschedule(String jobName,
String groupName)
throws SchedulerException
- Specified by:
unschedule in interface SchedulerEngine
- Throws:
SchedulerException
update
public void update(Trigger trigger)
throws SchedulerException
- Specified by:
update in interface SchedulerEngine
- Throws:
SchedulerException
delete
protected void delete(org.quartz.Scheduler scheduler,
String groupName)
throws Exception
- Throws:
Exception
delete
protected void delete(org.quartz.Scheduler scheduler,
String jobName,
String groupName)
throws Exception
- Throws:
Exception
fixMaxLength
protected String fixMaxLength(String argument,
int maxLength)
getFullName
protected String getFullName(String jobName,
String groupName)
getJobState
protected JobState getJobState(org.quartz.JobDataMap jobDataMap)
getMessage
protected Message getMessage(org.quartz.JobDataMap jobDataMap)
getOriginalGroupName
protected String getOriginalGroupName(String groupName)
getQuartzTrigger
protected org.quartz.Trigger getQuartzTrigger(Trigger trigger)
throws SchedulerException
- Throws:
SchedulerException
getScheduledJob
protected SchedulerResponse getScheduledJob(org.quartz.Scheduler scheduler,
String jobName,
String groupName)
throws Exception
- Throws:
Exception
getScheduledJobs
protected List<SchedulerResponse> getScheduledJobs(org.quartz.Scheduler scheduler,
String groupName)
throws Exception
- Throws:
Exception
getScheduler
protected org.quartz.Scheduler getScheduler(String groupName)
throws Exception
- Throws:
Exception
getStorageType
protected StorageType getStorageType(String groupName)
initializeScheduler
protected org.quartz.Scheduler initializeScheduler(String propertiesPrefix,
boolean useQuartzCluster)
throws Exception
- Throws:
Exception
initJobState
protected void initJobState()
throws Exception
- Throws:
Exception
pause
protected void pause(org.quartz.Scheduler scheduler,
String groupName)
throws Exception
- Throws:
Exception
pause
protected void pause(org.quartz.Scheduler scheduler,
String jobName,
String groupName)
throws Exception
- Throws:
Exception
resume
protected void resume(org.quartz.Scheduler scheduler,
String groupName)
throws Exception
- Throws:
Exception
resume
protected void resume(org.quartz.Scheduler scheduler,
String jobName,
String groupName)
throws Exception
- Throws:
Exception
schedule
protected void schedule(org.quartz.Scheduler scheduler,
StorageType storageType,
org.quartz.Trigger trigger,
String description,
String destinationName,
Message message)
throws Exception
- Throws:
Exception
suppressError
protected void suppressError(String jobName,
String groupName,
org.quartz.Scheduler scheduler)
throws Exception
- Throws:
Exception
unschedule
protected void unschedule(String groupName,
org.quartz.Scheduler scheduler)
throws Exception
- Throws:
Exception
unschedule
protected void unschedule(String jobName,
String groupName,
org.quartz.Scheduler scheduler)
throws Exception
- Throws:
Exception
update
protected void update(org.quartz.Scheduler scheduler,
Trigger trigger)
throws Exception
- Throws:
Exception
updateJobState
protected void updateJobState(org.quartz.Scheduler scheduler,
String jobName,
String groupName,
TriggerState triggerState,
boolean suppressError)
throws Exception
- Throws:
Exception