T
- public abstract class WorkflowXCommand<T> extends XCommand<T>
Modifier and Type | Field and Description |
---|---|
protected static String |
INSTR_FAILED_JOBS_COUNTER_NAME |
protected static String |
INSTR_KILLED_JOBS_COUNTER_NAME |
protected static String |
INSTR_SUCCEEDED_JOBS_COUNTER_NAME |
DEFAULT_LOCK_TIMEOUT, DEFAULT_REQUEUE_DELAY, dryrun, eventService, instrumentation, INSTRUMENTATION_GROUP, LOG, logInfo
Constructor and Description |
---|
WorkflowXCommand(String name,
String type,
int priority)
Base class constructor for workflow commands.
|
WorkflowXCommand(String name,
String type,
int priority,
boolean dryrun)
Base class constructor for workflow commands.
|
Modifier and Type | Method and Description |
---|---|
protected void |
generateEvent(WorkflowActionBean wfAction,
String wfUser) |
protected static void |
generateEvent(WorkflowJobBean wfJob) |
protected static void |
generateEvent(WorkflowJobBean wfJob,
String errorCode,
String errorMsg) |
protected void |
updateParentIfNecessary(WorkflowJobBean wfjob) |
protected void |
updateParentIfNecessary(WorkflowJobBean wfjob,
int maxRetries) |
call, call, eagerLoadState, eagerVerifyPrecondition, execute, executeInterrupts, getCreatedTime, getEntityKey, getInstrumentation, getKey, getLockTimeOut, getLog, getName, getPriority, getRequeueDelay, getType, inInterruptMode, isLockRequired, isReQueueRequired, loadState, queue, queue, resetUsed, setInterruptMode, toString, verifyPrecondition
protected static final String INSTR_SUCCEEDED_JOBS_COUNTER_NAME
protected static final String INSTR_KILLED_JOBS_COUNTER_NAME
protected static final String INSTR_FAILED_JOBS_COUNTER_NAME
public WorkflowXCommand(String name, String type, int priority)
name
- command nametype
- command typepriority
- command prioritypublic WorkflowXCommand(String name, String type, int priority, boolean dryrun)
name
- command nametype
- command typepriority
- command prioritydryrun
- true if rerun is enabled for commandprotected static void generateEvent(WorkflowJobBean wfJob, String errorCode, String errorMsg)
protected static void generateEvent(WorkflowJobBean wfJob)
protected void generateEvent(WorkflowActionBean wfAction, String wfUser)
protected void updateParentIfNecessary(WorkflowJobBean wfjob, int maxRetries) throws CommandException
CommandException
protected void updateParentIfNecessary(WorkflowJobBean wfjob) throws CommandException
CommandException
Copyright © 2014 Apache Software Foundation. All Rights Reserved.