Liferay 7.0-ce-m3

com.liferay.portal.scheduler
Class ClusterSchedulerEngine

java.lang.Object
  extended by com.liferay.portal.scheduler.ClusterSchedulerEngine
All Implemented Interfaces:
IdentifiableBean, SchedulerEngine

public class ClusterSchedulerEngine
extends Object
implements IdentifiableBean, SchedulerEngine


Field Summary
protected  SchedulerEngine schedulerEngine
           
 
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
ClusterSchedulerEngine(SchedulerEngine schedulerEngine)
           
 
Method Summary
static SchedulerEngine createClusterSchedulerEngine(SchedulerEngine schedulerEngine)
           
 void delete(String groupName, StorageType storageType)
           
 void delete(String jobName, String groupName, StorageType storageType)
           
 String getBeanIdentifier()
           
protected  String getFullName(String jobName, String groupName)
           
 SchedulerResponse getScheduledJob(String jobName, String groupName, StorageType storageType)
           
 List<SchedulerResponse> getScheduledJobs()
           
 List<SchedulerResponse> getScheduledJobs(StorageType storageType)
           
 List<SchedulerResponse> getScheduledJobs(String groupName, StorageType storageType)
           
protected  void initMemoryClusteredJobs()
           
protected  boolean isMemoryClusteredSlaveJob(StorageType storageType)
           
 void pause(String groupName, StorageType storageType)
           
 void pause(String jobName, String groupName, StorageType storageType)
           
protected  void removeMemoryClusteredJobs(String groupName)
           
 void resume(String groupName, StorageType storageType)
           
 void resume(String jobName, String groupName, StorageType storageType)
           
 void schedule(Trigger trigger, String description, String destinationName, Message message, StorageType storageType)
           
 void setBeanIdentifier(String beanIdentifier)
           
protected  void setClusterableThreadLocal(StorageType storageType)
           
 void shutdown()
           
 void start()
           
 void suppressError(String jobName, String groupName, StorageType storageType)
           
 void unschedule(String groupName, StorageType storageType)
           
 void unschedule(String jobName, String groupName, StorageType storageType)
           
 void update(Trigger trigger, StorageType storageType)
           
protected  void updateMemoryClusteredJob(String jobName, String groupName, TriggerState triggerState)
           
protected  void updateMemoryClusteredJobs(String groupName, TriggerState triggerState)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

schedulerEngine

@BeanReference(name="com.liferay.portal.scheduler.ClusterSchedulerEngineService")
protected SchedulerEngine schedulerEngine
Constructor Detail

ClusterSchedulerEngine

public ClusterSchedulerEngine(SchedulerEngine schedulerEngine)
Method Detail

createClusterSchedulerEngine

public static SchedulerEngine createClusterSchedulerEngine(SchedulerEngine schedulerEngine)

delete

@Clusterable(acceptor=com.liferay.portal.scheduler.ClusterSchedulerEngine.SchedulerClusterInvokeAcceptor.class)
public void delete(String groupName,
                                                                                                                               StorageType storageType)
            throws SchedulerException
Specified by:
delete in interface SchedulerEngine
Throws:
SchedulerException

delete

@Clusterable(acceptor=com.liferay.portal.scheduler.ClusterSchedulerEngine.SchedulerClusterInvokeAcceptor.class)
public void delete(String jobName,
                                                                                                                               String groupName,
                                                                                                                               StorageType storageType)
            throws SchedulerException
Specified by:
delete in interface SchedulerEngine
Throws:
SchedulerException

getBeanIdentifier

public String getBeanIdentifier()
Specified by:
getBeanIdentifier in interface IdentifiableBean

getScheduledJob

@Clusterable(onMaster=true)
public SchedulerResponse getScheduledJob(String jobName,
                                                             String groupName,
                                                             StorageType storageType)
                                  throws SchedulerException
Specified by:
getScheduledJob in interface SchedulerEngine
Throws:
SchedulerException

getScheduledJobs

@Clusterable(onMaster=true)
public List<SchedulerResponse> getScheduledJobs()
                                         throws SchedulerException
Specified by:
getScheduledJobs in interface SchedulerEngine
Throws:
SchedulerException

getScheduledJobs

@Clusterable(onMaster=true)
public List<SchedulerResponse> getScheduledJobs(StorageType storageType)
                                         throws SchedulerException
Specified by:
getScheduledJobs in interface SchedulerEngine
Throws:
SchedulerException

getScheduledJobs

@Clusterable(onMaster=true)
public List<SchedulerResponse> getScheduledJobs(String groupName,
                                                                    StorageType storageType)
                                         throws SchedulerException
Specified by:
getScheduledJobs in interface SchedulerEngine
Throws:
SchedulerException

pause

@Clusterable(acceptor=com.liferay.portal.scheduler.ClusterSchedulerEngine.SchedulerClusterInvokeAcceptor.class)
public void pause(String groupName,
                                                                                                                              StorageType storageType)
           throws SchedulerException
Specified by:
pause in interface SchedulerEngine
Throws:
SchedulerException

pause

@Clusterable(acceptor=com.liferay.portal.scheduler.ClusterSchedulerEngine.SchedulerClusterInvokeAcceptor.class)
public void pause(String jobName,
                                                                                                                              String groupName,
                                                                                                                              StorageType storageType)
           throws SchedulerException
Specified by:
pause in interface SchedulerEngine
Throws:
SchedulerException

resume

@Clusterable(acceptor=com.liferay.portal.scheduler.ClusterSchedulerEngine.SchedulerClusterInvokeAcceptor.class)
public void resume(String groupName,
                                                                                                                               StorageType storageType)
            throws SchedulerException
Specified by:
resume in interface SchedulerEngine
Throws:
SchedulerException

resume

@Clusterable(acceptor=com.liferay.portal.scheduler.ClusterSchedulerEngine.SchedulerClusterInvokeAcceptor.class)
public void resume(String jobName,
                                                                                                                               String groupName,
                                                                                                                               StorageType storageType)
            throws SchedulerException
Specified by:
resume in interface SchedulerEngine
Throws:
SchedulerException

schedule

@Clusterable(acceptor=com.liferay.portal.scheduler.ClusterSchedulerEngine.SchedulerClusterInvokeAcceptor.class)
public void schedule(Trigger trigger,
                                                                                                                                 String description,
                                                                                                                                 String destinationName,
                                                                                                                                 Message message,
                                                                                                                                 StorageType storageType)
              throws SchedulerException
Specified by:
schedule in interface SchedulerEngine
Throws:
SchedulerException

setBeanIdentifier

public void setBeanIdentifier(String beanIdentifier)
Specified by:
setBeanIdentifier in interface IdentifiableBean

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

@Clusterable(acceptor=com.liferay.portal.scheduler.ClusterSchedulerEngine.SchedulerClusterInvokeAcceptor.class)
public void suppressError(String jobName,
                                                                                                                                      String groupName,
                                                                                                                                      StorageType storageType)
                   throws SchedulerException
Specified by:
suppressError in interface SchedulerEngine
Throws:
SchedulerException

unschedule

@Clusterable(acceptor=com.liferay.portal.scheduler.ClusterSchedulerEngine.SchedulerClusterInvokeAcceptor.class)
public void unschedule(String groupName,
                                                                                                                                   StorageType storageType)
                throws SchedulerException
Specified by:
unschedule in interface SchedulerEngine
Throws:
SchedulerException

unschedule

@Clusterable(acceptor=com.liferay.portal.scheduler.ClusterSchedulerEngine.SchedulerClusterInvokeAcceptor.class)
public void unschedule(String jobName,
                                                                                                                                   String groupName,
                                                                                                                                   StorageType storageType)
                throws SchedulerException
Specified by:
unschedule in interface SchedulerEngine
Throws:
SchedulerException

update

@Clusterable(acceptor=com.liferay.portal.scheduler.ClusterSchedulerEngine.SchedulerClusterInvokeAcceptor.class)
public void update(Trigger trigger,
                                                                                                                               StorageType storageType)
            throws SchedulerException
Specified by:
update in interface SchedulerEngine
Throws:
SchedulerException

getFullName

protected String getFullName(String jobName,
                             String groupName)

initMemoryClusteredJobs

protected void initMemoryClusteredJobs()
                                throws Exception
Throws:
Exception

isMemoryClusteredSlaveJob

protected boolean isMemoryClusteredSlaveJob(StorageType storageType)

removeMemoryClusteredJobs

protected void removeMemoryClusteredJobs(String groupName)

setClusterableThreadLocal

protected void setClusterableThreadLocal(StorageType storageType)

updateMemoryClusteredJob

protected void updateMemoryClusteredJob(String jobName,
                                        String groupName,
                                        TriggerState triggerState)

updateMemoryClusteredJobs

protected void updateMemoryClusteredJobs(String groupName,
                                         TriggerState triggerState)

Liferay 7.0-ce-m3