Package org.cyclos.impl.messaging
Class MessageProcessingBackgroundTask
- java.lang.Object
-
- org.cyclos.impl.AbstractServerComponent
-
- org.cyclos.impl.AbstractGlobalServerComponent
-
- org.cyclos.impl.utils.tasks.AbstractTask
-
- org.cyclos.impl.utils.tasks.AbstractBackgroundTask
-
- org.cyclos.impl.messaging.MessageProcessingBackgroundTask
-
- All Implemented Interfaces:
BackgroundTask,HasMessageKey
@Component public class MessageProcessingBackgroundTask extends AbstractBackgroundTask
ABackgroundTaskthat process each incoming message to check if an e-mail should be sent.
NOTE: We execute a bulk insert to create theIncomingMessagefrom aOutgoingMessageand the corresponding task executions are created with a trigger (see triggers.ddl).
-
-
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 MessageProcessingBackgroundTask()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected longdoExecute(String context)Must be implemented to actually execute the task logic, returning the number of affected recordsMessageKeygetMessageKey()-
Methods inherited from class org.cyclos.impl.utils.tasks.AbstractBackgroundTask
execute, isVerbose, logName, runInEntityNetwork, runInNetwork
-
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, toString, wait, wait, wait
-
Methods inherited from interface org.cyclos.impl.utils.tasks.BackgroundTask
getName
-
-
-
-
Method Detail
-
getMessageKey
public MessageKey getMessageKey()
-
doExecute
protected long doExecute(String context)
Description copied from class:AbstractBackgroundTaskMust be implemented to actually execute the task logic, returning the number of affected records- Specified by:
doExecutein classAbstractBackgroundTask
-
-