Package org.cyclos.impl.banking

Class AccountVerificationPollingTask

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.banking.AccountVerificationPollingTask

All Implemented Interfaces:

Runnable, PollingTask, HasMessageKey

@Component
public class AccountVerificationPollingTask
extends SimplePollingTask

A PollingTask which verifies accounts. It actually does 3 things:

1. On first execution, rebuilds all closed account balances using NativeQueryHandler.rebuildClosedAccountBalances()
2. Closes balances since the last closing using NativeQueryHandler.closeAccountBalances()
3. Fixes any inconsistent account balances using NativeQueryHandler#fixInconsistentAccountBalances()

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
AccountVerificationPollingTask()

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.

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, logTaskSuccess, 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

AccountVerificationPollingTask

public AccountVerificationPollingTask()

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