Class JobProcessorService
- java.lang.Object
-
- com.avoka.fc.core.service.BaseService
-
- com.avoka.fc.core.service.CayenneService
-
- com.avoka.fc.core.service.job.impl.JobProcessorService
-
- All Implemented Interfaces:
IJobProcessor
public class JobProcessorService extends CayenneService implements IJobProcessor
Provides a Job Processor Service for processing all Collaboration Jobs- Since:
- 20.11.0
-
-
Constructor Summary
Constructors Constructor Description JobProcessorService()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
interruptProcessing()
Interrupt ongoing job processing.void
processJobs()
Process the list of collaboration jobs in the system that are ready to be processed.JobProcessorService
setUnitTest()
The unit tests sets this value to avoid time delays in job processing.-
Methods inherited from class com.avoka.fc.core.service.CayenneService
commitChanges, deleteObject, deleteObjects, findObject, getDataContext, getDataDomain, getObjectForPK, getObjectStore, newObject, performNamedQuery, performNamedQuery, performNamedQuery, performNonSelectingQuery, performNonSelectingQuery, performNonSelectingQuery, performNonSelectingQuery, performQuery, performQuery, refetchEntity, refetchObject, registerNewObject, rollbackChanges, toMap, toMap
-
Methods inherited from class com.avoka.fc.core.service.BaseService
getLogger
-
-
-
-
Method Detail
-
processJobs
public void processJobs()
Description copied from interface:IJobProcessor
Process the list of collaboration jobs in the system that are ready to be processed.- Specified by:
processJobs
in interfaceIJobProcessor
-
interruptProcessing
public void interruptProcessing()
Description copied from interface:IJobProcessor
Interrupt ongoing job processing. This does not happen instantaneously, but the service will check at suitable occasions (e.g. after processing a job) and stop processing.- Specified by:
interruptProcessing
in interfaceIJobProcessor
-
setUnitTest
public JobProcessorService setUnitTest()
The unit tests sets this value to avoid time delays in job processing.- Returns:
- this Job Processor Service
-
-