Liferay 6.2-ce-ga5

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
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
 
Constructor Summary
QuartzSchedulerEngine()
           
 
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
 

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)
            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

Liferay 6.2-ce-ga5