public class JobXCommand extends WorkflowXCommand<WorkflowJobBean>
INSTR_FAILED_JOBS_COUNTER_NAME, INSTR_KILLED_JOBS_COUNTER_NAME, INSTR_SUCCEEDED_JOBS_COUNTER_NAME
DEFAULT_LOCK_TIMEOUT, DEFAULT_REQUEUE_DELAY, dryrun, eventService, instrumentation, INSTRUMENTATION_GROUP, LOG, logInfo
Constructor and Description |
---|
JobXCommand(String id) |
JobXCommand(String id,
int start,
int length)
Constructor used to retrieve WF Job
|
Modifier and Type | Method and Description |
---|---|
protected WorkflowJobBean |
execute()
Command execution body.
|
String |
getEntityKey()
Return the entity key for the command.
|
protected boolean |
isLockRequired()
Indicate if the the command requires locking.
|
protected void |
loadState()
Load the necessary state to perform the precondition check and to execute the command.
|
protected void |
verifyPrecondition()
Verify the precondition for the command after a lock has been obtain, just before executing the command.
|
generateEvent, generateEvent, generateEvent, updateParentIfNecessary, updateParentIfNecessary
call, call, eagerLoadState, eagerVerifyPrecondition, executeInterrupts, getCreatedTime, getInstrumentation, getKey, getLockTimeOut, getLog, getName, getPriority, getRequeueDelay, getType, inInterruptMode, isReQueueRequired, queue, queue, resetUsed, setInterruptMode, toString
public JobXCommand(String id)
public JobXCommand(String id, int start, int length)
id
- wf jobIdstart
- starting index in the list of actions belonging to the joblength
- number of actions to be returnedprotected WorkflowJobBean execute() throws CommandException
XCommand
This method will be invoked after the {link #loadState} and {link #verifyPrecondition} methods.
If the command requires locking, this method will be invoked ONLY if the lock has been acquired.
execute
in class XCommand<WorkflowJobBean>
CommandException
- thrown if the command execution failed.public String getEntityKey()
XCommand
getEntityKey
in interface XCallable<WorkflowJobBean>
getEntityKey
in class XCommand<WorkflowJobBean>
protected boolean isLockRequired()
XCommand
Subclasses should override this method if they require locking.
isLockRequired
in class XCommand<WorkflowJobBean>
true/false
protected void loadState() throws CommandException
XCommand
Subclasses must implement this method and load the state needed to do the precondition check and execute the command.
loadState
in class XCommand<WorkflowJobBean>
CommandException
protected void verifyPrecondition() throws CommandException, PreconditionException
XCommand
verifyPrecondition
in class XCommand<WorkflowJobBean>
CommandException
- thrown if the precondition is not met.PreconditionException
Copyright © 2014 Apache Software Foundation. All Rights Reserved.