Package org.cyclos.impl.utils.tasks

Class PollingTaskHandlerImpl

java.lang.Object

org.cyclos.impl.AbstractServerComponent

org.cyclos.impl.AbstractGlobalServerComponent

org.cyclos.impl.BaseGlobalHandlerImpl

org.cyclos.impl.utils.tasks.PollingTaskHandlerImpl

All Implemented Interfaces:

ApplicationInitializationListener, PollingTaskHandler, PollingTaskHandlerImplementor

@Component
public class PollingTaskHandlerImpl
extends BaseGlobalHandlerImpl
implements PollingTaskHandlerImplementor, ApplicationInitializationListener

Implementation for PollingTaskHandler

Field Summary

Fields inherited from class org.cyclos.impl.AbstractGlobalServerComponent

rawEntityManagerHandler

Fields inherited from class org.cyclos.impl.AbstractServerComponent

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

Fields inherited from interface org.cyclos.impl.ApplicationInitializationListener

MAX_PRIORITY, MIN_PRIORITY, NORMAL_PRIORITY

Constructor Summary

Constructors

Constructor	Description
PollingTaskHandlerImpl()

Method Summary

Modifier and Type	Method	Description
void	awakeNow(PollingTask pollingTask)	Awakes the given PollingTask's thread now.
void	cancelTasks()	Cancels schedulings for all PollingTasks
<T extends PollingTask> T	getTask(Class<T> pollingTaskType)	Returns a PollingTaskHandler by class
void	onApplicationInitialization()	Invoked when the application service is initialized
void	onTaskFinished(PollingTask pollingTask)	Indicates that the task has finished executing
void	onTaskStarted(PollingTask pollingTask)	Indicates that the task has started executing
void	reschedule(Class<? extends PollingTask> pollingTaskType, Date nextExecution)	Reschedules the given PollingTask to run after the given Date
void	scheduleAwake(Class<? extends PollingTask> pollingTaskType)	Schedules an awake for the PollingTask of the given type after the current invocation ends
void	scheduleTasks()	Schedules all PollingTask executions (if not already started)

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, toString, wait, wait, wait

Methods inherited from interface org.cyclos.impl.ApplicationInitializationListener

applicationInitializationPriority, getInitializationId

Constructor Detail

PollingTaskHandlerImpl

public PollingTaskHandlerImpl()

Method Detail

awakeNow

public void awakeNow(PollingTask pollingTask)

Description copied from interface: PollingTaskHandlerImplementor

Awakes the given PollingTask's thread now. Not intended to be used by business services, as invoking it within a DB transaction would probably result in data to be processed not yet visible to the PollingTask, which runs in a separated DB transaction.

Specified by:

awakeNow in interface PollingTaskHandlerImplementor

cancelTasks

public void cancelTasks()

Description copied from interface: PollingTaskHandlerImplementor

Cancels schedulings for all PollingTasks

Specified by:

cancelTasks in interface PollingTaskHandlerImplementor

getTask

public <T extends PollingTask> T getTask(Class<T> pollingTaskType)

Description copied from interface: PollingTaskHandlerImplementor

Returns a PollingTaskHandler by class

Specified by:

getTask in interface PollingTaskHandlerImplementor

onApplicationInitialization

public void onApplicationInitialization()

Description copied from interface: ApplicationInitializationListener

Invoked when the application service is initialized

Specified by:

onApplicationInitialization in interface ApplicationInitializationListener

onTaskFinished

public void onTaskFinished(PollingTask pollingTask)

Description copied from interface: PollingTaskHandlerImplementor

Indicates that the task has finished executing

Specified by:

onTaskFinished in interface PollingTaskHandlerImplementor

onTaskStarted

public void onTaskStarted(PollingTask pollingTask)

Description copied from interface: PollingTaskHandlerImplementor

Indicates that the task has started executing

Specified by:

onTaskStarted in interface PollingTaskHandlerImplementor

reschedule

public void reschedule(Class<? extends PollingTask> pollingTaskType,
                       Date nextExecution)

Description copied from interface: PollingTaskHandlerImplementor

Reschedules the given PollingTask to run after the given Date

Specified by:

reschedule in interface PollingTaskHandlerImplementor

scheduleAwake

public void scheduleAwake(Class<? extends PollingTask> pollingTaskType)

Description copied from interface: PollingTaskHandler

Schedules an awake for the PollingTask of the given type after the current invocation ends

Specified by:

scheduleAwake in interface PollingTaskHandler

scheduleTasks

public void scheduleTasks()

Description copied from interface: PollingTaskHandlerImplementor

Schedules all PollingTask executions (if not already started)

Specified by:

scheduleTasks in interface PollingTaskHandlerImplementor