com.liferay.portal.scheduler
Class ClusterSchedulerEngine
java.lang.Object
com.liferay.portal.scheduler.ClusterSchedulerEngine
- All Implemented Interfaces:
- IdentifiableBean, SchedulerEngine
public class ClusterSchedulerEngine
- extends Object
- implements IdentifiableBean, 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 |
|
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 |
schedulerEngine
@BeanReference(name="com.liferay.portal.scheduler.ClusterSchedulerEngineService")
protected SchedulerEngine schedulerEngine
ClusterSchedulerEngine
public ClusterSchedulerEngine(SchedulerEngine schedulerEngine)
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)