Package org.cyclos.impl.access

Class PurgeSessionsPollingTask

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.access.PurgeSessionsPollingTask

All Implemented Interfaces:

Runnable, PollingTask, HasMessageKey

@Component
public class PurgeSessionsPollingTask
extends SimplePollingTask

A PollingTask which purges expired Sessions from the database. It runs every minute, and suppress logs, to avoid too many logs for this task.

Field Summary

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

clusterHandler, 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
PurgeSessionsPollingTask()

Method Summary

Modifier and Type	Method	Description
protected long	execute()	Executes the task batch.
PollingTaskFirstExecution	getFirstExecution()	Returns the polling task first execution
MessageKey	getMessageKey()
PollingTaskRecurrence	getRecurrence()	Return the polling task recurrence
protected boolean	isRunInTransaction()	Return whether the execute method must be ran in a transaction or not.
protected void	logTaskSuccess(String context, long timeTaken, long affectedRecords)

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

doRun, notifyIssueToLicense, notifyIssueToLicense

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

getStorage, isVerbose, logName, run, toString

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

getLogConfiguration, getName, logTaskError, resolveName, shouldGenerateErrorLog

Methods inherited from class org.cyclos.impl.AbstractGlobalServerComponent

getBaseEntityManagerHandler, getEntityManager

Methods inherited from class org.cyclos.impl.AbstractServerComponent

dataTranslationProxy, dataTranslationProxy, delete, detach, doDataTranslationProxy, 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

Methods inherited from interface org.cyclos.impl.utils.tasks.PollingTask

getName

Constructor Detail

PurgeSessionsPollingTask

public PurgeSessionsPollingTask()

Method Detail

getFirstExecution

public PollingTaskFirstExecution getFirstExecution()

Description copied from interface: PollingTask

Returns the polling task first execution

Specified by:

getFirstExecution in interface PollingTask

Overrides:

getFirstExecution in class AbstractPollingTask

getMessageKey

public MessageKey getMessageKey()

getRecurrence

public PollingTaskRecurrence getRecurrence()

Description copied from interface: PollingTask

Return the polling task recurrence

Specified by:

getRecurrence in interface PollingTask

Overrides:

getRecurrence 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

isRunInTransaction

protected boolean isRunInTransaction()

Description copied from class: SimplePollingTask

Return whether the execute method must be ran in a transaction or not. By default a transaction is opened before execute the method.

Overrides:

isRunInTransaction in class SimplePollingTask

logTaskSuccess

protected void logTaskSuccess(String context,
                              long timeTaken,
                              long affectedRecords)

Overrides:

logTaskSuccess in class AbstractTask