public class CoordPushDependencyCheckXCommand extends CoordinatorXCommand<Void>
Modifier and Type | Field and Description |
---|---|
protected String |
actionId |
static String |
CONF_COORD_PUSH_CHECK_REQUEUE_INTERVAL
Property name of command re-queue interval for coordinator push check in
milliseconds.
|
protected CoordinatorActionBean |
coordAction |
protected CoordinatorJobBean |
coordJob |
protected JPAService |
jpaService |
DEFAULT_LOCK_TIMEOUT, DEFAULT_REQUEUE_DELAY, dryrun, eventService, instrumentation, INSTRUMENTATION_GROUP, LOG
Modifier | Constructor and Description |
---|---|
|
CoordPushDependencyCheckXCommand(String actionId) |
|
CoordPushDependencyCheckXCommand(String actionId,
boolean registerForNotification) |
|
CoordPushDependencyCheckXCommand(String actionId,
boolean registerForNotification,
boolean removeAvailDependencies) |
protected |
CoordPushDependencyCheckXCommand(String actionName,
String actionId) |
Modifier and Type | Method and Description |
---|---|
protected Void |
execute()
Command execution body.
|
long |
getCoordPushCheckRequeueInterval()
Return the re-queue interval for coord push dependency check
|
String |
getEntityKey()
Return the entity key for the command.
|
String |
getKey()
Get command key
|
protected boolean |
isLockRequired()
Indicate if the the command requires locking.
|
protected boolean |
isTimeout()
Returns true if timeout period has been reached
|
protected void |
loadState()
Load the necessary state to perform the precondition check and to execute the command.
|
protected void |
onAllPushDependenciesAvailable(boolean isPullDependencyMeet) |
protected void |
setLogInfo()
Set the thread local logInfo with the context of this command and reset log prefix.
|
static void |
unregisterMissingDependencies(List<String> missingDeps,
String actionId) |
protected void |
updateCoordAction(CoordinatorActionBean coordAction,
boolean isChangeInDependency) |
protected void |
verifyPrecondition()
Verify the precondition for the command after a lock has been obtain, just before executing the command.
|
generateEvent, generateEvent
call, eagerLoadState, eagerVerifyPrecondition, executeInterrupts, getCreatedTime, getInstrumentation, getLockTimeOut, getLog, getName, getPriority, getRequeueDelay, getType, inInterruptMode, isReQueueRequired, queue, queue, resetUsed, setInterruptMode, toString
protected JPAService jpaService
protected CoordinatorActionBean coordAction
protected CoordinatorJobBean coordJob
public static final String CONF_COORD_PUSH_CHECK_REQUEUE_INTERVAL
public CoordPushDependencyCheckXCommand(String actionId)
public CoordPushDependencyCheckXCommand(String actionId, boolean registerForNotification)
public CoordPushDependencyCheckXCommand(String actionId, boolean registerForNotification, boolean removeAvailDependencies)
protected CoordPushDependencyCheckXCommand(String actionName, String actionId)
protected void setLogInfo()
XCommand
setLogInfo
in class XCommand<Void>
protected Void 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<Void>
CommandException
- thrown if the command execution failed.public long getCoordPushCheckRequeueInterval()
protected boolean isTimeout()
protected void onAllPushDependenciesAvailable(boolean isPullDependencyMeet) throws CommandException
CommandException
protected void updateCoordAction(CoordinatorActionBean coordAction, boolean isChangeInDependency) throws CommandException
CommandException
public static void unregisterMissingDependencies(List<String> missingDeps, String actionId)
public String getEntityKey()
XCommand
getEntityKey
in interface XCallable<Void>
getEntityKey
in class XCommand<Void>
protected boolean isLockRequired()
XCommand
Subclasses should override this method if they require locking.
isLockRequired
in class XCommand<Void>
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<Void>
CommandException
protected void verifyPrecondition() throws CommandException, PreconditionException
XCommand
verifyPrecondition
in class XCommand<Void>
CommandException
- thrown if the precondition is not met.PreconditionException
Copyright © 2018 Apache Software Foundation. All rights reserved.