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 |
AUDIT_ACTION, 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, SCRIPT, START_TIME, STORAGE_TYPE |
Method Summary |
void |
afterPropertiesSet()
|
void |
delete(String groupName)
|
void |
delete(String jobName,
String groupName)
|
void |
destroy()
|
protected String |
fixMaxLength(String argument,
int maxLength)
|
protected JobState |
getJobState(org.quartz.JobDataMap jobDataMap)
|
protected Message |
getMessage(org.quartz.JobDataMap jobDataMap)
|
protected MessageListener |
getMessageListener(String messageListenerClassName,
ClassLoader classLoader)
|
protected String |
getOriginalGroupName(String groupName)
|
protected org.quartz.Trigger |
getQuartzTrigger(Trigger trigger)
|
protected SchedulerResponse |
getScheduledJob(org.quartz.Scheduler scheduler,
org.quartz.JobKey jobKey)
|
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()
|
void |
pause(String groupName)
|
void |
pause(String jobName,
String groupName)
|
protected void |
registerMessageListeners(String jobName,
String groupName,
String destinationName,
Message message)
|
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 |
unregisterMessageListener(org.quartz.Scheduler scheduler,
org.quartz.JobKey jobKey)
|
protected void |
unschedule(org.quartz.Scheduler scheduler,
org.quartz.JobKey jobKey)
|
void |
unschedule(String groupName)
|
void |
unschedule(String jobName,
String groupName)
|
protected void |
update(org.quartz.Scheduler scheduler,
Trigger trigger)
|
void |
update(Trigger trigger)
|
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)
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
fixMaxLength
protected String fixMaxLength(String argument,
int maxLength)
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
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,
org.quartz.JobKey jobKey)
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
registerMessageListeners
protected void registerMessageListeners(String jobName,
String groupName,
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)
throws Exception
- Throws:
Exception
updateJobState
protected void updateJobState(org.quartz.Scheduler scheduler,
org.quartz.JobKey jobKey,
TriggerState triggerState,
boolean suppressError)
throws Exception
- Throws:
Exception