Package org.camunda.bpm.engine.impl.cmd

Class AcquireJobsCmd

java.lang.Object

org.camunda.bpm.engine.impl.cmd.AcquireJobsCmd

All Implemented Interfaces:

OptimisticLockingListener, Command<AcquiredJobs>

public class AcquireJobsCmd
extends Object
implements Command<AcquiredJobs>, OptimisticLockingListener

Author:

Nick Burch, Daniel Meyer

Field Summary

Fields

Modifier and Type	Field	Description
protected AcquiredJobs	acquiredJobs
protected int	numJobsToAcquire

Constructor Summary

Constructors

Constructor	Description
AcquireJobsCmd(JobExecutor jobExecutor)
AcquireJobsCmd(JobExecutor jobExecutor, int numJobsToAcquire)

Method Summary

Modifier and Type	Method	Description
AcquiredJobs	execute(CommandContext commandContext)
OptimisticLockingResult	failedOperation(DbOperation operation)	Signifies that an operation failed due to optimistic locking.
Class<? extends DbEntity>	getEntityType()	The type of the entity for which this listener should be notified.
protected boolean	isAcquireExclusiveOverProcessHierarchies(CommandContext context)
protected void	lockJob(AcquirableJobEntity job)
protected String	selectProcessInstanceId(AcquirableJobEntity job, boolean isAcquireExclusiveOverProcessHierarchies)

Methods inherited from class java.lang.Object

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

Field Details

acquiredJobs

protected AcquiredJobs acquiredJobs

numJobsToAcquire

protected int numJobsToAcquire

Constructor Details

AcquireJobsCmd

public AcquireJobsCmd(JobExecutor jobExecutor)

AcquireJobsCmd

public AcquireJobsCmd(JobExecutor jobExecutor,
 int numJobsToAcquire)

Method Details

execute

public AcquiredJobs execute(CommandContext commandContext)

Specified by:

execute in interface Command<AcquiredJobs>

lockJob

protected void lockJob(AcquirableJobEntity job)

getEntityType

public Class<? extends DbEntity> getEntityType()

Description copied from interface: OptimisticLockingListener

The type of the entity for which this listener should be notified. If the implementation returns 'null', the listener is notified for all entity types.

Specified by:

getEntityType in interface OptimisticLockingListener

Returns:

the entity type for which the listener should be notified.

failedOperation

public OptimisticLockingResult failedOperation(DbOperation operation)

Description copied from interface: OptimisticLockingListener

Signifies that an operation failed due to optimistic locking.

Specified by:

failedOperation in interface OptimisticLockingListener

Parameters:

operation - the failed operation.

Returns:

OptimisticLockingResult that instructs the caller how to handle the result of the failed operation.

isAcquireExclusiveOverProcessHierarchies

protected boolean isAcquireExclusiveOverProcessHierarchies(CommandContext context)

selectProcessInstanceId

protected String selectProcessInstanceId(AcquirableJobEntity job,
 boolean isAcquireExclusiveOverProcessHierarchies)