com.liferay.portal.scheduler
Class SchedulerEngineHelperImpl

java.lang.Object
  com.liferay.portal.scheduler.SchedulerEngineHelperImpl

All Implemented Interfaces:

SchedulerEngineHelper

public class SchedulerEngineHelperImpl
extends Object
implements SchedulerEngineHelper

Constructor Summary

SchedulerEngineHelperImpl()

Method Summary

void	addJob(Trigger trigger, StorageType storageType, String description, String destinationName, Message message, String messageListenerClassName, String portletId, int exceptionsMaxSize)
void	addJob(Trigger trigger, StorageType storageType, String description, String destinationName, Object payload, String messageListenerClassName, String portletId, int exceptionsMaxSize)
void	addScriptingJob(Trigger trigger, StorageType storageType, String description, String language, String script, int exceptionsMaxSize)
protected void	addWeeklyDayPos(PortletRequest portletRequest, List<DayAndPosition> list, int day)
void	auditSchedulerJobs(Message message, TriggerState triggerState)
void	delete(SchedulerEntry schedulerEntry, StorageType storageType)
void	delete(String groupName, StorageType storageType)
void	delete(String jobName, String groupName, StorageType storageType)
String	getCronText(Calendar calendar, boolean timeZoneSensitive)
String	getCronText(PortletRequest portletRequest, Calendar calendar, boolean timeZoneSensitive, int recurrenceType)
Date	getEndTime(SchedulerResponse schedulerResponse)
Date	getEndTime(String jobName, String groupName, StorageType storageType)
Date	getFinalFireTime(SchedulerResponse schedulerResponse)
Date	getFinalFireTime(String jobName, String groupName, StorageType storageType)
ObjectValuePair<Exception,Date>[]	getJobExceptions(SchedulerResponse schedulerResponse)
ObjectValuePair<Exception,Date>[]	getJobExceptions(String jobName, String groupName, StorageType storageType)
TriggerState	getJobState(SchedulerResponse schedulerResponse)
TriggerState	getJobState(String jobName, String groupName, StorageType storageType)
Date	getNextFireTime(SchedulerResponse schedulerResponse)
Date	getNextFireTime(String jobName, String groupName, StorageType storageType)
Date	getPreviousFireTime(SchedulerResponse schedulerResponse)
Date	getPreviousFireTime(String jobName, String groupName, StorageType storageType)
SchedulerResponse	getScheduledJob(String jobName, String groupName, StorageType storageType)
List<SchedulerResponse>	getScheduledJobs()
List<SchedulerResponse>	getScheduledJobs(StorageType storageType)
List<SchedulerResponse>	getScheduledJobs(String groupName, StorageType storageType)
Date	getStartTime(SchedulerResponse schedulerResponse)
Date	getStartTime(String jobName, String groupName, StorageType storageType)
void	initialize()
String	namespaceGroupName(String groupName, StorageType storageType)
void	pause(String groupName, StorageType storageType)
void	pause(String jobName, String groupName, StorageType storageType)
void	resume(String groupName, StorageType storageType)
void	resume(String jobName, String groupName, StorageType storageType)
void	schedule(SchedulerEntry schedulerEntry, StorageType storageType, String portletId, int exceptionsMaxSize)
void	schedule(Trigger trigger, StorageType storageType, String description, String destinationName, Message message, int exceptionsMaxSize)
void	schedule(Trigger trigger, StorageType storageType, String description, String destinationName, Object payload, int exceptionsMaxSize)
void	setSchedulerEngine(SchedulerEngine schedulerEngine)
void	shutdown()
void	start()
void	suppressError(String jobName, String groupName, StorageType storageType)
void	unschedule(SchedulerEntry schedulerEntry, StorageType storageType)
void	unschedule(String groupName, StorageType storageType)
void	unschedule(String jobName, String groupName, StorageType storageType)
void	update(String jobName, String groupName, StorageType storageType, String description, String language, String script, int exceptionsMaxSize)
void	update(Trigger trigger, StorageType storageType)
void	updateMemorySchedulerClusterMaster()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SchedulerEngineHelperImpl

public SchedulerEngineHelperImpl()

Method Detail

addJob

public void addJob(Trigger trigger,
                   StorageType storageType,
                   String description,
                   String destinationName,
                   Message message,
                   String messageListenerClassName,
                   String portletId,
                   int exceptionsMaxSize)
            throws SchedulerException

Specified by:

addJob in interface SchedulerEngineHelper

Throws:

SchedulerException

addJob

public void addJob(Trigger trigger,
                   StorageType storageType,
                   String description,
                   String destinationName,
                   Object payload,
                   String messageListenerClassName,
                   String portletId,
                   int exceptionsMaxSize)
            throws SchedulerException

Specified by:

addJob in interface SchedulerEngineHelper

Throws:

SchedulerException

addScriptingJob

public void addScriptingJob(Trigger trigger,
                            StorageType storageType,
                            String description,
                            String language,
                            String script,
                            int exceptionsMaxSize)
                     throws SchedulerException

Specified by:

addScriptingJob in interface SchedulerEngineHelper

Throws:

SchedulerException

auditSchedulerJobs

public void auditSchedulerJobs(Message message,
                               TriggerState triggerState)
                        throws SchedulerException

Specified by:

auditSchedulerJobs in interface SchedulerEngineHelper

Throws:

SchedulerException

delete

public void delete(SchedulerEntry schedulerEntry,
                   StorageType storageType)
            throws SchedulerException

Specified by:

delete in interface SchedulerEngineHelper

Throws:

SchedulerException

delete

public void delete(String groupName,
                   StorageType storageType)
            throws SchedulerException

Specified by:

delete in interface SchedulerEngineHelper

Throws:

SchedulerException

delete

public void delete(String jobName,
                   String groupName,
                   StorageType storageType)
            throws SchedulerException

Specified by:

delete in interface SchedulerEngineHelper

Throws:

SchedulerException

getCronText

public String getCronText(Calendar calendar,
                          boolean timeZoneSensitive)

Specified by:

getCronText in interface SchedulerEngineHelper

getCronText

public String getCronText(PortletRequest portletRequest,
                          Calendar calendar,
                          boolean timeZoneSensitive,
                          int recurrenceType)

Specified by:

getCronText in interface SchedulerEngineHelper

getEndTime

public Date getEndTime(SchedulerResponse schedulerResponse)

Specified by:

getEndTime in interface SchedulerEngineHelper

getEndTime

public Date getEndTime(String jobName,
                       String groupName,
                       StorageType storageType)
                throws SchedulerException

Specified by:

getEndTime in interface SchedulerEngineHelper

Throws:

SchedulerException

getFinalFireTime

public Date getFinalFireTime(SchedulerResponse schedulerResponse)

Specified by:

getFinalFireTime in interface SchedulerEngineHelper

getFinalFireTime

public Date getFinalFireTime(String jobName,
                             String groupName,
                             StorageType storageType)
                      throws SchedulerException

Specified by:

getFinalFireTime in interface SchedulerEngineHelper

Throws:

SchedulerException

getJobExceptions

public ObjectValuePair<Exception,Date>[] getJobExceptions(SchedulerResponse schedulerResponse)

Specified by:

getJobExceptions in interface SchedulerEngineHelper

getJobExceptions

public ObjectValuePair<Exception,Date>[] getJobExceptions(String jobName,
                                                          String groupName,
                                                          StorageType storageType)
                                                   throws SchedulerException

Specified by:

getJobExceptions in interface SchedulerEngineHelper

Throws:

SchedulerException

getJobState

public TriggerState getJobState(SchedulerResponse schedulerResponse)

Specified by:

getJobState in interface SchedulerEngineHelper

getJobState

public TriggerState getJobState(String jobName,
                                String groupName,
                                StorageType storageType)
                         throws SchedulerException

Specified by:

getJobState in interface SchedulerEngineHelper

Throws:

SchedulerException

getNextFireTime

public Date getNextFireTime(SchedulerResponse schedulerResponse)

Specified by:

getNextFireTime in interface SchedulerEngineHelper

getNextFireTime

public Date getNextFireTime(String jobName,
                            String groupName,
                            StorageType storageType)
                     throws SchedulerException

Specified by:

getNextFireTime in interface SchedulerEngineHelper

Throws:

SchedulerException

getPreviousFireTime

public Date getPreviousFireTime(SchedulerResponse schedulerResponse)

Specified by:

getPreviousFireTime in interface SchedulerEngineHelper

getPreviousFireTime

public Date getPreviousFireTime(String jobName,
                                String groupName,
                                StorageType storageType)
                         throws SchedulerException

Specified by:

getPreviousFireTime in interface SchedulerEngineHelper

Throws:

SchedulerException

getScheduledJob

public SchedulerResponse getScheduledJob(String jobName,
                                         String groupName,
                                         StorageType storageType)
                                  throws SchedulerException

Specified by:

getScheduledJob in interface SchedulerEngineHelper

Throws:

SchedulerException

getScheduledJobs

public List<SchedulerResponse> getScheduledJobs()
                                         throws SchedulerException

Specified by:

getScheduledJobs in interface SchedulerEngineHelper

Throws:

SchedulerException

getScheduledJobs

public List<SchedulerResponse> getScheduledJobs(StorageType storageType)
                                         throws SchedulerException

Specified by:

getScheduledJobs in interface SchedulerEngineHelper

Throws:

SchedulerException

getScheduledJobs

public List<SchedulerResponse> getScheduledJobs(String groupName,
                                                StorageType storageType)
                                         throws SchedulerException

Specified by:

getScheduledJobs in interface SchedulerEngineHelper

Throws:

SchedulerException

getStartTime

public Date getStartTime(SchedulerResponse schedulerResponse)

Specified by:

getStartTime in interface SchedulerEngineHelper

getStartTime

public Date getStartTime(String jobName,
                         String groupName,
                         StorageType storageType)
                  throws SchedulerException

Specified by:

getStartTime in interface SchedulerEngineHelper

Throws:

SchedulerException

initialize

public void initialize()
                throws SchedulerException

Specified by:

initialize in interface SchedulerEngineHelper

Throws:

SchedulerException

namespaceGroupName

public String namespaceGroupName(String groupName,
                                 StorageType storageType)

Specified by:

namespaceGroupName in interface SchedulerEngineHelper

pause

public void pause(String groupName,
                  StorageType storageType)
           throws SchedulerException

Specified by:

pause in interface SchedulerEngineHelper

Throws:

SchedulerException

pause

public void pause(String jobName,
                  String groupName,
                  StorageType storageType)
           throws SchedulerException

Specified by:

pause in interface SchedulerEngineHelper

Throws:

SchedulerException

resume

public void resume(String groupName,
                   StorageType storageType)
            throws SchedulerException

Specified by:

resume in interface SchedulerEngineHelper

Throws:

SchedulerException

resume

public void resume(String jobName,
                   String groupName,
                   StorageType storageType)
            throws SchedulerException

Specified by:

resume in interface SchedulerEngineHelper

Throws:

SchedulerException

schedule

public void schedule(SchedulerEntry schedulerEntry,
                     StorageType storageType,
                     String portletId,
                     int exceptionsMaxSize)
              throws SchedulerException

Specified by:

schedule in interface SchedulerEngineHelper

Throws:

SchedulerException

schedule

public void schedule(Trigger trigger,
                     StorageType storageType,
                     String description,
                     String destinationName,
                     Message message,
                     int exceptionsMaxSize)
              throws SchedulerException

Specified by:

schedule in interface SchedulerEngineHelper

Throws:

SchedulerException

schedule

public void schedule(Trigger trigger,
                     StorageType storageType,
                     String description,
                     String destinationName,
                     Object payload,
                     int exceptionsMaxSize)
              throws SchedulerException

Specified by:

schedule in interface SchedulerEngineHelper

Throws:

SchedulerException

setSchedulerEngine

public void setSchedulerEngine(SchedulerEngine schedulerEngine)

shutdown

public void shutdown()
              throws SchedulerException

Specified by:

shutdown in interface SchedulerEngineHelper

Throws:

SchedulerException

start

public void start()
           throws SchedulerException

Specified by:

start in interface SchedulerEngineHelper

Throws:

SchedulerException

suppressError

public void suppressError(String jobName,
                          String groupName,
                          StorageType storageType)
                   throws SchedulerException

Specified by:

suppressError in interface SchedulerEngineHelper

Throws:

SchedulerException

unschedule

public void unschedule(SchedulerEntry schedulerEntry,
                       StorageType storageType)
                throws SchedulerException

Specified by:

unschedule in interface SchedulerEngineHelper

Throws:

SchedulerException

unschedule

public void unschedule(String groupName,
                       StorageType storageType)
                throws SchedulerException

Specified by:

unschedule in interface SchedulerEngineHelper

Throws:

SchedulerException

unschedule

public void unschedule(String jobName,
                       String groupName,
                       StorageType storageType)
                throws SchedulerException

Specified by:

unschedule in interface SchedulerEngineHelper

Throws:

SchedulerException

update

public void update(String jobName,
                   String groupName,
                   StorageType storageType,
                   String description,
                   String language,
                   String script,
                   int exceptionsMaxSize)
            throws SchedulerException

Specified by:

update in interface SchedulerEngineHelper

Throws:

SchedulerException

update

public void update(Trigger trigger,
                   StorageType storageType)
            throws SchedulerException

Specified by:

update in interface SchedulerEngineHelper

Throws:

SchedulerException

updateMemorySchedulerClusterMaster

public void updateMemorySchedulerClusterMaster()
                                        throws SchedulerException

Specified by:

updateMemorySchedulerClusterMaster in interface SchedulerEngineHelper

Throws:

SchedulerException

addWeeklyDayPos

protected void addWeeklyDayPos(PortletRequest portletRequest,
                               List<DayAndPosition> list,
                               int day)