public class ClusterSchedulerEngine
extends java.lang.Object
implements com.liferay.portal.kernel.module.framework.service.IdentifiableOSGiService, com.liferay.portal.kernel.scheduler.SchedulerEngine
| Modifier and Type | Field and Description |
|---|---|
protected static java.lang.String |
PLUGIN_READY |
protected static java.lang.String |
PORTAL_READY |
protected static java.lang.String |
SCHEDULER_CLUSTER_INVOKING |
DESCRIPTION, DESTINATION_NAME, DISABLE, END_TIME, EXCEPTIONS_MAX_SIZE, FINAL_FIRE_TIME, GROUP_NAME, JOB_NAME, 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 and Description |
|---|
ClusterSchedulerEngine(com.liferay.portal.kernel.scheduler.SchedulerEngine schedulerEngine) |
| Modifier and Type | Method and Description |
|---|---|
void |
delete(java.lang.String groupName,
com.liferay.portal.kernel.scheduler.StorageType storageType) |
void |
delete(java.lang.String jobName,
java.lang.String groupName,
com.liferay.portal.kernel.scheduler.StorageType storageType) |
protected java.lang.String |
getFullName(java.lang.String jobName,
java.lang.String groupName) |
java.lang.String |
getOSGiServiceIdentifier() |
com.liferay.portal.kernel.scheduler.messaging.SchedulerResponse |
getScheduledJob(java.lang.String jobName,
java.lang.String groupName,
com.liferay.portal.kernel.scheduler.StorageType storageType) |
java.util.List<com.liferay.portal.kernel.scheduler.messaging.SchedulerResponse> |
getScheduledJobs() |
java.util.List<com.liferay.portal.kernel.scheduler.messaging.SchedulerResponse> |
getScheduledJobs(com.liferay.portal.kernel.scheduler.StorageType storageType) |
java.util.List<com.liferay.portal.kernel.scheduler.messaging.SchedulerResponse> |
getScheduledJobs(java.lang.String groupName,
com.liferay.portal.kernel.scheduler.StorageType storageType) |
protected void |
initMemoryClusteredJobs() |
protected boolean |
isMemoryClusteredSlaveJob(com.liferay.portal.kernel.scheduler.StorageType storageType) |
void |
pause(java.lang.String groupName,
com.liferay.portal.kernel.scheduler.StorageType storageType) |
void |
pause(java.lang.String jobName,
java.lang.String groupName,
com.liferay.portal.kernel.scheduler.StorageType storageType) |
protected void |
removeMemoryClusteredJobs(java.lang.String groupName) |
void |
resume(java.lang.String groupName,
com.liferay.portal.kernel.scheduler.StorageType storageType) |
void |
resume(java.lang.String jobName,
java.lang.String groupName,
com.liferay.portal.kernel.scheduler.StorageType storageType) |
void |
schedule(com.liferay.portal.kernel.scheduler.Trigger trigger,
java.lang.String description,
java.lang.String destinationName,
com.liferay.portal.kernel.messaging.Message message,
com.liferay.portal.kernel.scheduler.StorageType storageType) |
protected void |
setClusterableThreadLocal(com.liferay.portal.kernel.scheduler.StorageType storageType) |
protected void |
setClusterMasterExecutor(com.liferay.portal.kernel.cluster.ClusterMasterExecutor clusterMasterExecutor) |
protected void |
setProps(com.liferay.portal.kernel.util.Props props) |
void |
shutdown() |
void |
start() |
void |
suppressError(java.lang.String jobName,
java.lang.String groupName,
com.liferay.portal.kernel.scheduler.StorageType storageType) |
void |
unschedule(java.lang.String groupName,
com.liferay.portal.kernel.scheduler.StorageType storageType) |
void |
unschedule(java.lang.String jobName,
java.lang.String groupName,
com.liferay.portal.kernel.scheduler.StorageType storageType) |
void |
update(com.liferay.portal.kernel.scheduler.Trigger trigger,
com.liferay.portal.kernel.scheduler.StorageType storageType) |
protected void |
updateMemoryClusteredJob(java.lang.String jobName,
java.lang.String groupName,
com.liferay.portal.kernel.scheduler.TriggerState triggerState) |
protected void |
updateMemoryClusteredJobs(java.lang.String groupName,
com.liferay.portal.kernel.scheduler.TriggerState triggerState) |
protected static final java.lang.String PLUGIN_READY
protected static final java.lang.String PORTAL_READY
protected static final java.lang.String SCHEDULER_CLUSTER_INVOKING
public ClusterSchedulerEngine(com.liferay.portal.kernel.scheduler.SchedulerEngine schedulerEngine)
@Clusterable(acceptor=SchedulerClusterInvokeAcceptor.class) public void delete(java.lang.String groupName, com.liferay.portal.kernel.scheduler.StorageType storageType) throws com.liferay.portal.kernel.scheduler.SchedulerException
delete in interface com.liferay.portal.kernel.scheduler.SchedulerEnginecom.liferay.portal.kernel.scheduler.SchedulerException@Clusterable(acceptor=SchedulerClusterInvokeAcceptor.class) public void delete(java.lang.String jobName, java.lang.String groupName, com.liferay.portal.kernel.scheduler.StorageType storageType) throws com.liferay.portal.kernel.scheduler.SchedulerException
delete in interface com.liferay.portal.kernel.scheduler.SchedulerEnginecom.liferay.portal.kernel.scheduler.SchedulerExceptionpublic java.lang.String getOSGiServiceIdentifier()
getOSGiServiceIdentifier in interface com.liferay.portal.kernel.module.framework.service.IdentifiableOSGiService@Clusterable(onMaster=true)
public com.liferay.portal.kernel.scheduler.messaging.SchedulerResponse getScheduledJob(java.lang.String jobName,
java.lang.String groupName,
com.liferay.portal.kernel.scheduler.StorageType storageType)
throws com.liferay.portal.kernel.scheduler.SchedulerException
getScheduledJob in interface com.liferay.portal.kernel.scheduler.SchedulerEnginecom.liferay.portal.kernel.scheduler.SchedulerException@Clusterable(onMaster=true)
public java.util.List<com.liferay.portal.kernel.scheduler.messaging.SchedulerResponse> getScheduledJobs()
throws com.liferay.portal.kernel.scheduler.SchedulerException
getScheduledJobs in interface com.liferay.portal.kernel.scheduler.SchedulerEnginecom.liferay.portal.kernel.scheduler.SchedulerException@Clusterable(onMaster=true)
public java.util.List<com.liferay.portal.kernel.scheduler.messaging.SchedulerResponse> getScheduledJobs(com.liferay.portal.kernel.scheduler.StorageType storageType)
throws com.liferay.portal.kernel.scheduler.SchedulerException
getScheduledJobs in interface com.liferay.portal.kernel.scheduler.SchedulerEnginecom.liferay.portal.kernel.scheduler.SchedulerException@Clusterable(onMaster=true)
public java.util.List<com.liferay.portal.kernel.scheduler.messaging.SchedulerResponse> getScheduledJobs(java.lang.String groupName,
com.liferay.portal.kernel.scheduler.StorageType storageType)
throws com.liferay.portal.kernel.scheduler.SchedulerException
getScheduledJobs in interface com.liferay.portal.kernel.scheduler.SchedulerEnginecom.liferay.portal.kernel.scheduler.SchedulerException@Clusterable(acceptor=SchedulerClusterInvokeAcceptor.class) public void pause(java.lang.String groupName, com.liferay.portal.kernel.scheduler.StorageType storageType) throws com.liferay.portal.kernel.scheduler.SchedulerException
pause in interface com.liferay.portal.kernel.scheduler.SchedulerEnginecom.liferay.portal.kernel.scheduler.SchedulerException@Clusterable(acceptor=SchedulerClusterInvokeAcceptor.class) public void pause(java.lang.String jobName, java.lang.String groupName, com.liferay.portal.kernel.scheduler.StorageType storageType) throws com.liferay.portal.kernel.scheduler.SchedulerException
pause in interface com.liferay.portal.kernel.scheduler.SchedulerEnginecom.liferay.portal.kernel.scheduler.SchedulerException@Clusterable(acceptor=SchedulerClusterInvokeAcceptor.class) public void resume(java.lang.String groupName, com.liferay.portal.kernel.scheduler.StorageType storageType) throws com.liferay.portal.kernel.scheduler.SchedulerException
resume in interface com.liferay.portal.kernel.scheduler.SchedulerEnginecom.liferay.portal.kernel.scheduler.SchedulerException@Clusterable(acceptor=SchedulerClusterInvokeAcceptor.class) public void resume(java.lang.String jobName, java.lang.String groupName, com.liferay.portal.kernel.scheduler.StorageType storageType) throws com.liferay.portal.kernel.scheduler.SchedulerException
resume in interface com.liferay.portal.kernel.scheduler.SchedulerEnginecom.liferay.portal.kernel.scheduler.SchedulerException@Clusterable(acceptor=SchedulerClusterInvokeAcceptor.class) public void schedule(com.liferay.portal.kernel.scheduler.Trigger trigger, java.lang.String description, java.lang.String destinationName, com.liferay.portal.kernel.messaging.Message message, com.liferay.portal.kernel.scheduler.StorageType storageType) throws com.liferay.portal.kernel.scheduler.SchedulerException
schedule in interface com.liferay.portal.kernel.scheduler.SchedulerEnginecom.liferay.portal.kernel.scheduler.SchedulerExceptionpublic void shutdown()
throws com.liferay.portal.kernel.scheduler.SchedulerException
shutdown in interface com.liferay.portal.kernel.scheduler.SchedulerEnginecom.liferay.portal.kernel.scheduler.SchedulerExceptionpublic void start()
throws com.liferay.portal.kernel.scheduler.SchedulerException
start in interface com.liferay.portal.kernel.scheduler.SchedulerEnginecom.liferay.portal.kernel.scheduler.SchedulerException@Clusterable(acceptor=SchedulerClusterInvokeAcceptor.class) public void suppressError(java.lang.String jobName, java.lang.String groupName, com.liferay.portal.kernel.scheduler.StorageType storageType) throws com.liferay.portal.kernel.scheduler.SchedulerException
suppressError in interface com.liferay.portal.kernel.scheduler.SchedulerEnginecom.liferay.portal.kernel.scheduler.SchedulerException@Clusterable(acceptor=SchedulerClusterInvokeAcceptor.class) public void unschedule(java.lang.String groupName, com.liferay.portal.kernel.scheduler.StorageType storageType) throws com.liferay.portal.kernel.scheduler.SchedulerException
unschedule in interface com.liferay.portal.kernel.scheduler.SchedulerEnginecom.liferay.portal.kernel.scheduler.SchedulerException@Clusterable(acceptor=SchedulerClusterInvokeAcceptor.class) public void unschedule(java.lang.String jobName, java.lang.String groupName, com.liferay.portal.kernel.scheduler.StorageType storageType) throws com.liferay.portal.kernel.scheduler.SchedulerException
unschedule in interface com.liferay.portal.kernel.scheduler.SchedulerEnginecom.liferay.portal.kernel.scheduler.SchedulerException@Clusterable(acceptor=SchedulerClusterInvokeAcceptor.class) public void update(com.liferay.portal.kernel.scheduler.Trigger trigger, com.liferay.portal.kernel.scheduler.StorageType storageType) throws com.liferay.portal.kernel.scheduler.SchedulerException
update in interface com.liferay.portal.kernel.scheduler.SchedulerEnginecom.liferay.portal.kernel.scheduler.SchedulerExceptionprotected java.lang.String getFullName(java.lang.String jobName,
java.lang.String groupName)
protected void initMemoryClusteredJobs()
throws java.lang.Exception
java.lang.Exceptionprotected boolean isMemoryClusteredSlaveJob(com.liferay.portal.kernel.scheduler.StorageType storageType)
protected void removeMemoryClusteredJobs(java.lang.String groupName)
protected void setClusterableThreadLocal(com.liferay.portal.kernel.scheduler.StorageType storageType)
protected void setClusterMasterExecutor(com.liferay.portal.kernel.cluster.ClusterMasterExecutor clusterMasterExecutor)
protected void setProps(com.liferay.portal.kernel.util.Props props)
protected void updateMemoryClusteredJob(java.lang.String jobName,
java.lang.String groupName,
com.liferay.portal.kernel.scheduler.TriggerState triggerState)
protected void updateMemoryClusteredJobs(java.lang.String groupName,
com.liferay.portal.kernel.scheduler.TriggerState triggerState)