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, CONTEXT_PATH, 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 String |
getFullName(String jobName,
String groupName)
|
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)
getFullName
protected String getFullName(String jobName,
String groupName)
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