Package org.flowable.job.service.impl.cmd

Class AcquireJobsCmd

java.lang.Object

org.flowable.job.service.impl.cmd.AcquireJobsCmd

All Implemented Interfaces:

Command<List<? extends JobInfoEntity>>

public class AcquireJobsCmd
extends Object
implements Command<List<? extends JobInfoEntity>>

Author:

Tijs Rademakers, Joram Barrez, Filip Hrisafov

Field Summary

Fields

Modifier and Type	Field	Description
protected AsyncExecutor	asyncExecutor
protected JobInfoEntityManager<? extends JobInfoEntity>	jobEntityManager
protected int	remainingCapacity

Constructor Summary

Constructors

Constructor	Description
AcquireJobsCmd(AsyncExecutor asyncExecutor)
AcquireJobsCmd(AsyncExecutor asyncExecutor, int remainingCapacity, JobInfoEntityManager<? extends JobInfoEntity> jobEntityManager)

Method Summary

Modifier and Type	Method	Description
protected GregorianCalendar	calculateLockExpirationTime(int lockTimeInMillis, JobServiceConfiguration jobServiceConfiguration)
List<? extends JobInfoEntity>	execute(CommandContext commandContext)
protected void	lockJob(JobInfoEntity job, int lockTimeInMillis, JobServiceConfiguration jobServiceConfiguration)

Methods inherited from class java.lang.Object

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

Field Details

asyncExecutor

protected AsyncExecutor asyncExecutor

remainingCapacity

protected int remainingCapacity

jobEntityManager

protected JobInfoEntityManager<? extends JobInfoEntity> jobEntityManager

Constructor Details

AcquireJobsCmd

public AcquireJobsCmd(AsyncExecutor asyncExecutor)

AcquireJobsCmd

public AcquireJobsCmd(AsyncExecutor asyncExecutor,
 int remainingCapacity,
 JobInfoEntityManager<? extends JobInfoEntity> jobEntityManager)

Method Details

execute

public List<? extends JobInfoEntity> execute(CommandContext commandContext)

Specified by:

execute in interface Command<List<? extends JobInfoEntity>>

lockJob

protected void lockJob(JobInfoEntity job,
 int lockTimeInMillis,
 JobServiceConfiguration jobServiceConfiguration)

calculateLockExpirationTime

protected GregorianCalendar calculateLockExpirationTime(int lockTimeInMillis,
 JobServiceConfiguration jobServiceConfiguration)