Package org.cyclos.impl.banking

Class InstallmentProcessingPollingTask

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.EntityBatchPollingTask<Installment>

org.cyclos.impl.banking.InstallmentProcessingPollingTask

All Implemented Interfaces:

Runnable, PollingTask

@Component
public class InstallmentProcessingPollingTask
extends EntityBatchPollingTask<Installment>

A PollingTask which processes installments of an scheduled payment

Field Summary

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

BATCH_SIZE, entityType

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

Method Summary

Modifier and Type	Method	Description
protected void	finish(Installment installment, Throwable error)	Must be implemented in order to mark the given entity as finished.
String	getName()	Returns the task name
protected boolean	logProcessingErrors(Installment entity)	Returns whether a log should be generated when an entity processing fails
protected Collection<Long>	nextIds()	Must be implemented in order to return the ids of the next entities to be processed, without actually processing them.
protected void	process(Installment installment)	Must be implemented in order to actually process the given entity, without change it's state to already processed
protected boolean	shouldGenerateErrorLog(Long networkId, Throwable error)

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

doRun, find, generateErrorLog, generateErrorLog, onFinish, resolveNetwork, shouldGenerateErrorLog, shouldSkipFinish

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

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

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

getLogConfiguration, logName, logTaskError, logTaskSuccess, 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

InstallmentProcessingPollingTask

public InstallmentProcessingPollingTask()

Method Detail

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

finish

protected void finish(Installment installment,
                      Throwable error)
               throws Throwable

Description copied from class: EntityBatchPollingTask

Must be implemented in order to mark the given entity as finished. Even when {@link #process(IEntity))} fails, this method is invoked. Runs in another transaction, passing the error if EntityBatchPollingTask.process(IEntity) yielded an error.

Specified by:

finish in class EntityBatchPollingTask<Installment>

Throws:

Throwable

logProcessingErrors

protected boolean logProcessingErrors(Installment entity)

Description copied from class: EntityBatchPollingTask

Returns whether a log should be generated when an entity processing fails

Overrides:

logProcessingErrors in class EntityBatchPollingTask<Installment>

nextIds

protected Collection<Long> nextIds()
                            throws Throwable

Description copied from class: EntityBatchPollingTask

Must be implemented in order to return the ids of the next entities to be processed, without actually processing them. Returning null or an empty list means there is no more data for now, and will make this task sleep

Specified by:

nextIds in class EntityBatchPollingTask<Installment>

Throws:

Throwable

process

protected void process(Installment installment)
                throws Throwable

Description copied from class: EntityBatchPollingTask

Must be implemented in order to actually process the given entity, without change it's state to already processed

Specified by:

process in class EntityBatchPollingTask<Installment>

Throws:

Throwable

shouldGenerateErrorLog

protected boolean shouldGenerateErrorLog(Long networkId,
                                         Throwable error)

Overrides:

shouldGenerateErrorLog in class EntityBatchPollingTask<Installment>