Package org.cyclos.impl.system

Class RunScheduledPollingTask

java.lang.Object

org.cyclos.impl.AbstractServerComponent

org.cyclos.impl.AbstractGlobalServerComponent

org.cyclos.impl.utils.tasks.AbstractTask

org.cyclos.impl.utils.tasks.AbstractPollingTask

org.cyclos.impl.utils.tasks.SimplePollingTask

org.cyclos.impl.system.RunScheduledPollingTask

All Implemented Interfaces:

Runnable, PollingTask

@Component
public class RunScheduledPollingTask
extends SimplePollingTask

A PollingTask which starts running custom scheduled tasks

Field Summary

Fields inherited from class org.cyclos.impl.utils.tasks.AbstractTask

errorLogService, invokerHandler, loggingHandler

Fields inherited from class org.cyclos.impl.AbstractGlobalServerComponent

rawEntityManagerHandler

Fields inherited from class org.cyclos.impl.AbstractServerComponent

accountHandler, configurationHandler, dataTranslationHandler, notificationHandler, profileFieldHandler, transactionHandler, translationHandler

Constructor Summary

Constructors

Constructor	Description
RunScheduledPollingTask()

Method Summary

Modifier and Type	Method	Description
protected long	execute()	Executes the task batch.
Date	getFirstExecution()	Returns the first execution time for this polling task
String	getName()	Returns the task name
Date	getNextExecution()	Returns the next time the task should be executed

Methods inherited from class org.cyclos.impl.utils.tasks.SimplePollingTask

doRun, isRunInTransaction

Methods inherited from class org.cyclos.impl.utils.tasks.AbstractPollingTask

dateFromDelay, getInitialSleepSeconds, getSecondsUntilNextDay, getSecondsUntilNextHour, getSleepSeconds, getStorage, initialize, isExclusiveInCluster, run

Methods inherited from class org.cyclos.impl.utils.tasks.AbstractTask

getLogConfiguration, logName, logTaskError, logTaskSuccess, shouldGenerateErrorLog, toString

Methods inherited from class org.cyclos.impl.AbstractGlobalServerComponent

getBaseEntityManagerHandler, getEntityManager

Methods inherited from class org.cyclos.impl.AbstractServerComponent

dataTranslationProxy, delete, detach, find, flush, from, getApplicationContext, getFormatter, getFormatter, getFormatter, getLogger, getRemoteAddress, getSessionData, mailContentBuilder, message, message, persist, processBatch, processBatch, refresh, remove, selectFrom, subQuery, update

Methods inherited from class java.lang.Object

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

Constructor Detail

RunScheduledPollingTask

public RunScheduledPollingTask()

Method Detail

getFirstExecution

public Date getFirstExecution()

Description copied from interface: PollingTask

Returns the first execution time for this polling task

Specified by:

getFirstExecution in interface PollingTask

Overrides:

getFirstExecution in class AbstractPollingTask

getName

public String getName()

Description copied from interface: PollingTask

Returns the task name

Specified by:

getName in interface PollingTask

Specified by:

getName in class AbstractTask

getNextExecution

public Date getNextExecution()

Description copied from interface: PollingTask

Returns the next time the task should be executed

Specified by:

getNextExecution in interface PollingTask

Overrides:

getNextExecution in class AbstractPollingTask

execute

protected long execute()
                throws Throwable

Description copied from class: SimplePollingTask

Executes the task batch. This method must be idempotent, which means that subsequent invocations should not cause side effects. For example, a task could expire data up to the current hour. If executed several times within any given hour, only the first execution should change data, while others should not affect anything. Should return the number of affected records

Specified by:

execute in class SimplePollingTask

Throws:

Throwable