Liferay 7.0-ce-m3

com.liferay.portal.scheduler.quartz
Class QuartzSchedulerEngine

java.lang.Object
  extended by com.liferay.portal.scheduler.quartz.QuartzSchedulerEngine
All Implemented Interfaces:
SchedulerEngine

public class QuartzSchedulerEngine
extends Object
implements SchedulerEngine


Field Summary
protected  QuartzLocalService quartzLocalService
           
 
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
 
Constructor Summary
QuartzSchedulerEngine()
           
 
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
 

Field Detail

quartzLocalService

@BeanReference(name="com.liferay.portal.service.QuartzLocalService")
protected QuartzLocalService quartzLocalService
Constructor Detail

QuartzSchedulerEngine

public QuartzSchedulerEngine()
Method Detail

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

Liferay 7.0-ce-m3