org.camunda.bpm.engine.impl.cmd

Class HistoryCleanupCmd

java.lang.Object

org.camunda.bpm.engine.impl.cmd.HistoryCleanupCmd

All Implemented Interfaces:

Command<Job>

public class HistoryCleanupCmd
extends Object
implements Command<Job>

Author:

Svetlana Dorokhova

Field Summary

Fields

Modifier and Type	Field and Description
static JobDeclaration	HISTORY_CLEANUP_JOB_DECLARATION
static int	MAX_THREADS_NUMBER

Constructor Summary

Constructors

Constructor and Description
HistoryCleanupCmd(boolean immediatelyDue)

Method Summary

Modifier and Type	Method and Description
protected HistoryCleanupContext	createCleanupContext(int[] minuteChunk)
protected JobEntity	createJob(int[] minuteChunk)
protected List<Job>	createJobs(int degreeOfParallelism, int[][] minuteChunks)
Job	execute(CommandContext commandContext)
protected List<Job>	getHistoryCleanupJobs()
protected List<Job>	reconfigureJobs(List<Job> historyCleanupJobs, int degreeOfParallelism, int[][] minuteChunks)
protected boolean	shouldCreateJobs(List<Job> jobs)
protected boolean	shouldReconfigureJobs(List<Job> jobs)
protected boolean	shouldSuspendJobs(List<Job> jobs)
protected void	suspendJobs(List<Job> jobs)
protected boolean	willBeScheduled()

Methods inherited from class java.lang.Object

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

Field Detail

HISTORY_CLEANUP_JOB_DECLARATION

public static final JobDeclaration HISTORY_CLEANUP_JOB_DECLARATION

MAX_THREADS_NUMBER

public static final int MAX_THREADS_NUMBER

See Also:

Constant Field Values

Constructor Detail

HistoryCleanupCmd

public HistoryCleanupCmd(boolean immediatelyDue)

Method Detail

execute

public Job execute(CommandContext commandContext)

Specified by:

execute in interface Command<Job>

getHistoryCleanupJobs

protected List<Job> getHistoryCleanupJobs()

shouldCreateJobs

protected boolean shouldCreateJobs(List<Job> jobs)

shouldReconfigureJobs

protected boolean shouldReconfigureJobs(List<Job> jobs)

shouldSuspendJobs

protected boolean shouldSuspendJobs(List<Job> jobs)

willBeScheduled

protected boolean willBeScheduled()

createJobs

protected List<Job> createJobs(int degreeOfParallelism,
                               int[][] minuteChunks)

reconfigureJobs

protected List<Job> reconfigureJobs(List<Job> historyCleanupJobs,
                                    int degreeOfParallelism,
                                    int[][] minuteChunks)

suspendJobs

protected void suspendJobs(List<Job> jobs)

createJob

protected JobEntity createJob(int[] minuteChunk)

createCleanupContext

protected HistoryCleanupContext createCleanupContext(int[] minuteChunk)