A BatchProcessor manages the running and monitoring of a potentially long-running transactional batch process. It iterates over a collection, and queues jobs that fire a worker on a batch of members. The queued jobs handle progress / error reporting, transaction delineation and retrying. They are processed in parallel by a pool of threads of a configurable size. The job processing is designed to be fault tolerant and will continue in the event of errors. When the batch is complete a summary of the number of errors and the last error stack trace will be logged at ERROR level. Each individual error is logged at WARN level and progress information is logged at INFO level. Through the BatchMonitor interface, it also supports the real-time monitoring of batch metrics (e.g. over JMX in the Enterprise Edition).

Nested Class Summary
abstract static class	BatchProcessor.BatchProcessWorkerAdaptor<TT>           Adaptor that allows implementations to only implement BatchProcessor.BatchProcessWorkerAdaptor.process(Object)

Constructor Summary

BatchProcessor(String processName, RetryingTransactionHelper retryingTransactionHelper, Collection<T> collection, int workerThreads, int batchSize, org.springframework.context.ApplicationEventPublisher applicationEventPublisher, org.apache.commons.logging.Log logger, int loggingInterval)           Deprecated. Since 3.4, use the BatchProcessWorkProvider instead of the Collection

BatchProcessor(String processName, RetryingTransactionHelper retryingTransactionHelper, BatchProcessWorkProvider<T> workProvider, int workerThreads, int batchSize, org.springframework.context.ApplicationEventPublisher applicationEventPublisher, org.apache.commons.logging.Log logger, int loggingInterval)           Instantiates a new batch processor.

Method Summary
String	getCurrentEntryId()
Date	getEndTime()
String	getLastError()
String	getLastErrorEntryId()
String	getPercentComplete()
String	getProcessName()
Date	getStartTime()
int	getSuccessfullyProcessedEntries()
int	getTotalErrors()
int	getTotalResults()
int	process(org.alfresco.repo.batch.BatchProcessor.BatchProcessWorker<T> worker, boolean splitTxns)           Invokes the worker for each entry in the collection, managing transactions and collating success / failure information.

Methods inherited from class java.lang.Object

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

Constructor Detail

Method Detail