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 |
DESCRIPTION, DESCRIPTION_MAX_LENGTH, DESTINATION_NAME, DISABLE, END_TIME, EXCEPTIONS_MAX_SIZE, FINAL_FIRE_TIME, GROUP_NAME, GROUP_NAME_MAX_LENGTH, JOB_NAME, JOB_NAME_MAX_LENGTH, JOB_STATE, LANGUAGE, MESSAGE, MESSAGE_LISTENER_CLASS_NAME, MESSAGE_LISTENER_UUID, NEXT_FIRE_TIME, PORTLET_ID, PREVIOUS_FIRE_TIME, RECEIVER_KEY, SCHEDULER, SCRIPT, START_TIME, STORAGE_TYPE |
|
Method Summary |
void |
afterPropertiesSet()
|
void |
delete(String groupName,
StorageType storageType)
|
void |
delete(String jobName,
String groupName,
StorageType storageType)
|
void |
destroy()
|
protected String |
fixMaxLength(String argument,
int maxLength,
StorageType storageType)
|
protected JobState |
getJobState(org.quartz.JobDataMap jobDataMap)
|
protected Message |
getMessage(org.quartz.JobDataMap jobDataMap)
|
protected MessageListener |
getMessageListener(String messageListenerClassName,
ClassLoader classLoader)
|
protected org.quartz.Trigger |
getQuartzTrigger(Trigger trigger,
StorageType storageType)
|
protected SchedulerResponse |
getScheduledJob(org.quartz.Scheduler scheduler,
org.quartz.JobKey jobKey)
|
SchedulerResponse |
getScheduledJob(String jobName,
String groupName,
StorageType storageType)
|
List<SchedulerResponse> |
getScheduledJobs()
|
protected List<SchedulerResponse> |
getScheduledJobs(org.quartz.Scheduler scheduler,
String groupName,
StorageType storageType)
|
List<SchedulerResponse> |
getScheduledJobs(StorageType storageType)
|
List<SchedulerResponse> |
getScheduledJobs(String groupName,
StorageType storageType)
|
protected org.quartz.Scheduler |
getScheduler(StorageType storageType)
|
protected StorageType |
getStorageType(String groupName)
|
protected org.quartz.Scheduler |
initializeScheduler(String propertiesPrefix,
boolean useQuartzCluster)
|
protected void |
initJobState()
|
void |
pause(String groupName,
StorageType storageType)
|
void |
pause(String jobName,
String groupName,
StorageType storageType)
|
protected void |
registerMessageListeners(String destinationName,
Message message)
|
void |
resume(String groupName,
StorageType storageType)
|
void |
resume(String jobName,
String groupName,
StorageType storageType)
|
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,
StorageType storageType)
|
void |
shutdown()
|
void |
start()
|
void |
suppressError(String jobName,
String groupName,
StorageType storageType)
|
protected void |
unregisterMessageListener(org.quartz.Scheduler scheduler,
org.quartz.JobKey jobKey)
|
protected void |
unschedule(org.quartz.Scheduler scheduler,
org.quartz.JobKey jobKey)
|
void |
unschedule(String groupName,
StorageType storageType)
|
void |
unschedule(String jobName,
String groupName,
StorageType storageType)
|
protected void |
update(org.quartz.Scheduler scheduler,
Trigger trigger,
StorageType storageType)
|
void |
update(Trigger trigger,
StorageType storageType)
|
protected void |
updateJobState(org.quartz.Scheduler scheduler,
org.quartz.JobKey jobKey,
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,
StorageType storageType)
throws SchedulerException
- Specified by:
delete in interface SchedulerEngine
- Throws:
SchedulerException
delete
public void delete(String jobName,
String groupName,
StorageType storageType)
throws SchedulerException
- Specified by:
delete in interface SchedulerEngine
- Throws:
SchedulerException
destroy
public void destroy()
getScheduledJob
public SchedulerResponse getScheduledJob(String jobName,
String groupName,
StorageType storageType)
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(StorageType storageType)
throws SchedulerException
- Specified by:
getScheduledJobs in interface SchedulerEngine
- Throws:
SchedulerException
getScheduledJobs
public List<SchedulerResponse> getScheduledJobs(String groupName,
StorageType storageType)
throws SchedulerException
- Specified by:
getScheduledJobs in interface SchedulerEngine
- Throws:
SchedulerException
pause
public void pause(String groupName,
StorageType storageType)
throws SchedulerException
- Specified by:
pause in interface SchedulerEngine
- Throws:
SchedulerException
pause
public void pause(String jobName,
String groupName,
StorageType storageType)
throws SchedulerException
- Specified by:
pause in interface SchedulerEngine
- Throws:
SchedulerException
resume
public void resume(String groupName,
StorageType storageType)
throws SchedulerException
- Specified by:
resume in interface SchedulerEngine
- Throws:
SchedulerException
resume
public void resume(String jobName,
String groupName,
StorageType storageType)
throws SchedulerException
- Specified by:
resume in interface SchedulerEngine
- Throws:
SchedulerException
schedule
public void schedule(Trigger trigger,
String description,
String destination,
Message message,
StorageType storageType)
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,
StorageType storageType)
throws SchedulerException
- Specified by:
suppressError in interface SchedulerEngine
- Throws:
SchedulerException
unschedule
public void unschedule(String groupName,
StorageType storageType)
throws SchedulerException
- Specified by:
unschedule in interface SchedulerEngine
- Throws:
SchedulerException
unschedule
public void unschedule(String jobName,
String groupName,
StorageType storageType)
throws SchedulerException
- Specified by:
unschedule in interface SchedulerEngine
- Throws:
SchedulerException
update
public void update(Trigger trigger,
StorageType storageType)
throws SchedulerException
- Specified by:
update in interface SchedulerEngine
- Throws:
SchedulerException
fixMaxLength
protected String fixMaxLength(String argument,
int maxLength,
StorageType storageType)
getJobState
protected JobState getJobState(org.quartz.JobDataMap jobDataMap)
getMessage
protected Message getMessage(org.quartz.JobDataMap jobDataMap)
getMessageListener
protected MessageListener getMessageListener(String messageListenerClassName,
ClassLoader classLoader)
throws SchedulerException
- Throws:
SchedulerException
getQuartzTrigger
protected org.quartz.Trigger getQuartzTrigger(Trigger trigger,
StorageType storageType)
throws SchedulerException
- Throws:
SchedulerException
getScheduledJob
protected SchedulerResponse getScheduledJob(org.quartz.Scheduler scheduler,
org.quartz.JobKey jobKey)
throws Exception
- Throws:
Exception
getScheduledJobs
protected List<SchedulerResponse> getScheduledJobs(org.quartz.Scheduler scheduler,
String groupName,
StorageType storageType)
throws Exception
- Throws:
Exception
getScheduler
protected org.quartz.Scheduler getScheduler(StorageType storageType)
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
registerMessageListeners
protected void registerMessageListeners(String destinationName,
Message message)
throws SchedulerException
- Throws:
SchedulerException
schedule
protected void schedule(org.quartz.Scheduler scheduler,
StorageType storageType,
org.quartz.Trigger trigger,
String description,
String destinationName,
Message message)
throws Exception
- Throws:
Exception
unregisterMessageListener
protected void unregisterMessageListener(org.quartz.Scheduler scheduler,
org.quartz.JobKey jobKey)
throws Exception
- Throws:
Exception
unschedule
protected void unschedule(org.quartz.Scheduler scheduler,
org.quartz.JobKey jobKey)
throws Exception
- Throws:
Exception
update
protected void update(org.quartz.Scheduler scheduler,
Trigger trigger,
StorageType storageType)
throws Exception
- Throws:
Exception
updateJobState
protected void updateJobState(org.quartz.Scheduler scheduler,
org.quartz.JobKey jobKey,
TriggerState triggerState,
boolean suppressError)
throws Exception
- Throws:
Exception