Package fr.becpg.repo.batch

Class BatchQueueServiceImpl

java.lang.Object

fr.becpg.repo.batch.BatchQueueServiceImpl

All Implemented Interfaces:

BatchQueueService, EventListener, org.springframework.context.ApplicationListener<org.alfresco.repo.batch.BatchMonitorEvent>

@Service("batchQueueService")
public class BatchQueueServiceImpl
extends Object
implements BatchQueueService, org.springframework.context.ApplicationListener<org.alfresco.repo.batch.BatchMonitorEvent>

BatchQueueServiceImpl class.

Version:

$Id: $Id

Author:

matthieu

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	BatchQueueServiceImpl.BatchCommand<T>
private class	BatchQueueServiceImpl.BatchStepWithErrorHandling

Field Summary

Fields

Modifier and Type	Field	Description
private org.springframework.context.ApplicationEventPublisher	applicationEventPublisher
private ReentrantLock	batchQueueLock
private BeCPGAuditService	beCPGAuditService
private BeCPGCacheService	beCPGCacheService
private BeCPGMailService	beCPGMailService
private static final String	CANCELLED
private Set<String>	cancelledBatches
private org.alfresco.repo.batch.BatchMonitor	lastRunningBatch
private static final org.apache.commons.logging.Log	logger
private org.alfresco.service.cmr.repository.NodeService	nodeService
private Deque<BatchQueueServiceImpl.BatchCommand<?>>	pausedCommands
private static final String	PERCENT_COMPLETED
private List<BatchQueueServiceImpl.BatchCommand<?>>	runningCommands
private static final String	STEP_COUNT
private static final String	STEPS_MAX
private org.alfresco.repo.tenant.TenantAdminService	tenantAdminService
private Map<String,ThreadPoolExecutor>	threadExecutorMap
private org.alfresco.service.transaction.TransactionService	transactionService

Constructor Summary

Constructors

Constructor	Description
BatchQueueServiceImpl()

Method Summary

Modifier and Type	Method	Description
private org.json.JSONObject	buildJsonBatchInfo(BatchInfo batchInfo)
boolean	cancelBatch(String batchId)	cancelBatch.
BatchStep<org.alfresco.service.cmr.repository.NodeRef>	createBatchStepWithErrorHandling(BatchInfo batchInfo, List<org.alfresco.service.cmr.repository.NodeRef> list, org.alfresco.repo.batch.BatchProcessor.BatchProcessWorker<org.alfresco.service.cmr.repository.NodeRef> processor)
private BatchQueueServiceImpl.BatchCommand<?>	findCommandInQueue(String batchId)
private Map<String,Set<org.alfresco.service.cmr.repository.NodeRef>>	getBatchErrorsMap()
String	getBatchesInError()
List<String>	getBatchesInQueue()	getBatchesInQueue.
org.alfresco.repo.batch.BatchMonitor	getLastRunningBatch()	getLastRunningBatch.
String	getRunningBatchInfo()	getRunningBatchInfo.
private BatchQueueServiceImpl.BatchCommand<?>	getRunningCommand()
boolean	isBatchInQueue(BatchInfo batchInfo)	isBatchInQueue.
void	onApplicationEvent(org.alfresco.repo.batch.BatchMonitorEvent event)
private void	processBatchErrors(List<org.alfresco.service.cmr.repository.NodeRef> nodeRefs, Map<String,Set<org.alfresco.service.cmr.repository.NodeRef>> batchNodesMap)
<T> Boolean	queueBatch(BatchInfo batchInfo, List<BatchStep<T>> batchSteps)	queueBatch.
<T> Boolean	queueBatch(BatchInfo batchInfo, List<BatchStep<T>> batchSteps, BatchClosingHook closingHook)	queueBatch.
<T> Boolean	queueBatch(BatchInfo batchInfo, org.alfresco.repo.batch.BatchProcessWorkProvider<T> workProvider, org.alfresco.repo.batch.BatchProcessor.BatchProcessWorker<T> processWorker, BatchErrorCallback errorCallback)	queueBatch.
private BatchInfo	removeBatchErrors(String batchId, List<org.alfresco.service.cmr.repository.NodeRef> nodeRefs)
boolean	removeBatchFromQueue(String batchId)	removeBatchFromQueue.
BatchInfo	retryBatchInError(String batchId)
String	viewErrors(String batchId)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.context.ApplicationListener

supportsAsyncExecution

Field Details

logger

private static final org.apache.commons.logging.Log logger

transactionService

@Autowired
private org.alfresco.service.transaction.TransactionService transactionService

applicationEventPublisher

@Autowired
private org.springframework.context.ApplicationEventPublisher applicationEventPublisher

beCPGMailService

@Autowired
private BeCPGMailService beCPGMailService

threadExecutorMap

@Autowired
@Qualifier("batchThreadPoolExecutorMap")
private Map<String,ThreadPoolExecutor> threadExecutorMap

tenantAdminService

@Autowired
private org.alfresco.repo.tenant.TenantAdminService tenantAdminService

beCPGAuditService

@Autowired
private BeCPGAuditService beCPGAuditService

beCPGCacheService

@Autowired
private BeCPGCacheService beCPGCacheService

nodeService

@Autowired
private org.alfresco.service.cmr.repository.NodeService nodeService

lastRunningBatch

private org.alfresco.repo.batch.BatchMonitor lastRunningBatch

runningCommands

private List<BatchQueueServiceImpl.BatchCommand<?>> runningCommands

cancelledBatches

private Set<String> cancelledBatches

pausedCommands

private Deque<BatchQueueServiceImpl.BatchCommand<?>> pausedCommands

batchQueueLock

private ReentrantLock batchQueueLock

CANCELLED

private static final String CANCELLED

See Also:

• Constant Field Values

PERCENT_COMPLETED

private static final String PERCENT_COMPLETED

See Also:

• Constant Field Values

STEPS_MAX

private static final String STEPS_MAX

See Also:

• Constant Field Values

STEP_COUNT

private static final String STEP_COUNT

See Also:

• Constant Field Values

Constructor Details

BatchQueueServiceImpl

public BatchQueueServiceImpl()

Method Details

queueBatch

public <T> Boolean queueBatch(@NonNull
 BatchInfo batchInfo,
 @NonNull
 org.alfresco.repo.batch.BatchProcessWorkProvider<T> workProvider,
 @NonNull
 org.alfresco.repo.batch.BatchProcessor.BatchProcessWorker<T> processWorker,
 @Nullable
 BatchErrorCallback errorCallback)

queueBatch.

Specified by:

queueBatch in interface BatchQueueService

Type Parameters:

T - a T class

Parameters:

batchInfo - a BatchInfo object

workProvider - a BatchProcessWorkProvider object

processWorker - a BatchProcessor.BatchProcessWorker object

errorCallback - a BatchErrorCallback object

Returns:

a Boolean object

queueBatch

public <T> Boolean queueBatch(@NonNull
 BatchInfo batchInfo,
 @NonNull
 List<BatchStep<T>> batchSteps)

queueBatch.

Specified by:

queueBatch in interface BatchQueueService

Type Parameters:

T - a T class

Parameters:

batchInfo - a BatchInfo object

batchSteps - a List object

Returns:

a Boolean object

queueBatch

public <T> Boolean queueBatch(@NonNull
 BatchInfo batchInfo,
 @NonNull
 List<BatchStep<T>> batchSteps,
 BatchClosingHook closingHook)

queueBatch.

Specified by:

queueBatch in interface BatchQueueService

Type Parameters:

T - a T class

Parameters:

batchInfo - a BatchInfo object

batchSteps - a List object

closingHook - a BatchClosingHook object

Returns:

a Boolean object

isBatchInQueue

public boolean isBatchInQueue(BatchInfo batchInfo)

isBatchInQueue.

Specified by:

isBatchInQueue in interface BatchQueueService

Parameters:

batchInfo - a BatchInfo object

Returns:

a boolean

getRunningBatchInfo

public String getRunningBatchInfo()

getRunningBatchInfo.

Specified by:

getRunningBatchInfo in interface BatchQueueService

Returns:

a String object

buildJsonBatchInfo

private org.json.JSONObject buildJsonBatchInfo(BatchInfo batchInfo)
                                        throws org.json.JSONException

Throws:

org.json.JSONException

getLastRunningBatch

public org.alfresco.repo.batch.BatchMonitor getLastRunningBatch()

getLastRunningBatch.

Specified by:

getLastRunningBatch in interface BatchQueueService

Returns:

a BatchMonitor object

getRunningCommand

private BatchQueueServiceImpl.BatchCommand<?> getRunningCommand()

getBatchesInQueue

public List<String> getBatchesInQueue()

getBatchesInQueue.

Specified by:

getBatchesInQueue in interface BatchQueueService

Returns:

a List object

removeBatchFromQueue

public boolean removeBatchFromQueue(String batchId)

removeBatchFromQueue.

Specified by:

removeBatchFromQueue in interface BatchQueueService

Parameters:

batchId - a String object

Returns:

a boolean

findCommandInQueue

private BatchQueueServiceImpl.BatchCommand<?> findCommandInQueue(String batchId)

cancelBatch

public boolean cancelBatch(String batchId)

cancelBatch.

Specified by:

cancelBatch in interface BatchQueueService

Parameters:

batchId - a String object

Returns:

a boolean

getBatchesInError

public String getBatchesInError()

Specified by:

getBatchesInError in interface BatchQueueService

getBatchErrorsMap

private Map<String,Set<org.alfresco.service.cmr.repository.NodeRef>> getBatchErrorsMap()

processBatchErrors

private void processBatchErrors(List<org.alfresco.service.cmr.repository.NodeRef> nodeRefs,
 Map<String,Set<org.alfresco.service.cmr.repository.NodeRef>> batchNodesMap)

retryBatchInError

public BatchInfo retryBatchInError(String batchId)

Specified by:

retryBatchInError in interface BatchQueueService

removeBatchErrors

private BatchInfo removeBatchErrors(String batchId,
 List<org.alfresco.service.cmr.repository.NodeRef> nodeRefs)

createBatchStepWithErrorHandling

public BatchStep<org.alfresco.service.cmr.repository.NodeRef> createBatchStepWithErrorHandling(BatchInfo batchInfo,
 List<org.alfresco.service.cmr.repository.NodeRef> list,
 org.alfresco.repo.batch.BatchProcessor.BatchProcessWorker<org.alfresco.service.cmr.repository.NodeRef> processor)

Specified by:

createBatchStepWithErrorHandling in interface BatchQueueService

viewErrors

public String viewErrors(String batchId)

Specified by:

viewErrors in interface BatchQueueService

onApplicationEvent

public void onApplicationEvent(org.alfresco.repo.batch.BatchMonitorEvent event)

Specified by:

onApplicationEvent in interface org.springframework.context.ApplicationListener<org.alfresco.repo.batch.BatchMonitorEvent>