Package fr.becpg.repo.batch

Class BatchQueueServiceImpl.BatchCommand<T>

java.lang.Object

fr.becpg.repo.batch.BatchQueueServiceImpl.BatchCommand<T>

All Implemented Interfaces:

Runnable

Enclosing class:

BatchQueueServiceImpl

public class BatchQueueServiceImpl.BatchCommand<T>
extends Object
implements Runnable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static final record	BatchQueueServiceImpl.BatchCommand.StepOutcome	What a step reported, whichever way it was run.

Field Summary

Fields

Modifier and Type	Field	Description
private AuditScope	auditScope
private String	batchId
private BatchInfo	batchInfo
private List<BatchStep<T>>	batchSteps
private BatchClosingHook	closingHook

Constructor Summary

Constructors

Constructor	Description
BatchCommand(BatchInfo batchInfo, List<BatchStep<T>> batchSteps, BatchClosingHook closingHook)

Method Summary

Modifier and Type	Method	Description
private String	asReportedByBatchProcessor(Throwable t)	Same shape as BatchProcessor.getLastError, so listeners see one thing.
private void	checkPausedCommand()
boolean	equals(Object obj)
String	getBatchId()
BatchInfo	getBatchInfo()
private BatchQueueServiceImpl	getEnclosingInstance()
private org.alfresco.repo.batch.BatchProcessWorkProvider<T>	getNextWorkWrapper(org.alfresco.repo.batch.BatchProcessWorkProvider<T> workProvider)
int	hashCode()
private void	pauseCommand(BatchQueueServiceImpl.BatchCommand<?> command)	Moves a command to the paused queue.
private void	pushAndSetBatchAuthentication(BatchStep<T> batchStep)
void	run()
private org.alfresco.repo.batch.BatchProcessor.BatchProcessWorker<T>	runAsWrapper(BatchStep<T> batchStep)
private BatchQueueServiceImpl.BatchCommand.StepOutcome	runStepInTransaction(BatchStep<T> batchStep)	The default: Alfresco's BatchProcessor opens a transaction around every entry.
private BatchQueueServiceImpl.BatchCommand.StepOutcome	runStepOutsideTransaction(BatchStep<T> batchStep)	Runs the step without opening a transaction around it, for work that waits on something other than the database and must not hold a transaction while it does.

Methods inherited from class java.lang.Object

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

Field Details

batchId

private String batchId

batchInfo

private BatchInfo batchInfo

batchSteps

private List<BatchStep<T>> batchSteps

closingHook

private BatchClosingHook closingHook

auditScope

private AuditScope auditScope

Constructor Details

BatchCommand

public BatchCommand(BatchInfo batchInfo,
 List<BatchStep<T>> batchSteps,
 BatchClosingHook closingHook)

Method Details

getBatchInfo

public BatchInfo getBatchInfo()

getBatchId

public String getBatchId()

run

public void run()

Specified by:

run in interface Runnable

pauseCommand

private void pauseCommand(BatchQueueServiceImpl.BatchCommand<?> command)

Moves a command to the paused queue. A paused command leaves the running list, so that the running list only ever names the batch that is actually progressing, and it is never queued twice, so that its own completion is enough to clear it from the paused queue.

pushAndSetBatchAuthentication

private void pushAndSetBatchAuthentication(BatchStep<T> batchStep)

getNextWorkWrapper

private org.alfresco.repo.batch.BatchProcessWorkProvider<T> getNextWorkWrapper(org.alfresco.repo.batch.BatchProcessWorkProvider<T> workProvider)

runStepInTransaction

private BatchQueueServiceImpl.BatchCommand.StepOutcome runStepInTransaction(BatchStep<T> batchStep)

The default: Alfresco's BatchProcessor opens a transaction around every entry.

runStepOutsideTransaction

private BatchQueueServiceImpl.BatchCommand.StepOutcome runStepOutsideTransaction(BatchStep<T> batchStep)

Runs the step without opening a transaction around it, for work that waits on something other than the database and must not hold a transaction while it does. The worker takes care of its own transactions. Everything the transactional path offers is kept: the same wrapper, so the same authentication, pause and cancellation handling and the same progress counter; one entry at a time, so a pause is honoured between entries; and an entry that throws is counted and logged without stopping the rest, as BatchProcessor does.

asReportedByBatchProcessor

private String asReportedByBatchProcessor(Throwable t)

Same shape as BatchProcessor.getLastError, so listeners see one thing.

runAsWrapper

private org.alfresco.repo.batch.BatchProcessor.BatchProcessWorker<T> runAsWrapper(BatchStep<T> batchStep)

checkPausedCommand

private void checkPausedCommand()

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

getEnclosingInstance

private BatchQueueServiceImpl getEnclosingInstance()