Package ca.corefacility.bioinformatics.irida.service

Class SequencingObjectProcessingService

java.lang.Object

ca.corefacility.bioinformatics.irida.service.SequencingObjectProcessingService

@Service
@Scope("singleton")
public class SequencingObjectProcessingService
extends java.lang.Object

Service used to run a FileProcessingChain on incoming SequencingObjects.

Constructor Summary

Constructors

Constructor	Description
SequencingObjectProcessingService(SequencingObjectRepository sequencingObjectRepository, org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor executor, FileProcessingChain fileProcessingChain)

Method Summary

Modifier and Type	Method	Description
void	findFilesToProcess()	Find new SequencingObjects to process and mark that this process is going to handle them
void	processFiles()	Process SequencingObjects that have been locked for processing
void	runProcessingJob()	Process new SequencingObjects uploaded and find new sequences to process next time around

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SequencingObjectProcessingService

@Autowired
public SequencingObjectProcessingService(SequencingObjectRepository sequencingObjectRepository,
                                         @Qualifier("fileProcessingChainExecutor")
                                         org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor executor,
                                         @Qualifier("uploadFileProcessingChain")
                                         FileProcessingChain fileProcessingChain)

Method Detail

runProcessingJob

public void runProcessingJob()

Process new SequencingObjects uploaded and find new sequences to process next time around

findFilesToProcess

public void findFilesToProcess()

Find new SequencingObjects to process and mark that this process is going to handle them

processFiles

public void processFiles()

Process SequencingObjects that have been locked for processing