public class SubscriptionSchedulerCmdImpl extends ControllerCommandImpl implements SubscriptionSchedulerCmd
The command exits if an unexpected error was encountered or when it has completed executing all actions until the batch size required is reached.
Modifier and Type | Field and Description |
---|---|
static java.lang.String | COPYRIGHT
IBM Copyright notice field.
|
static java.lang.String | SCHEDULED_ACTIONS_QUERY
The name of the query used to retrieve the list of scheduled actions.
|
Constructor and Description |
---|
SubscriptionSchedulerCmdImpl() |
Modifier and Type | Method and Description |
---|---|
protected int | getDelayBetweenRetries(java.lang.Long scheduledActionId, SubscriptionScheduledActionCmd actionCmd)
This method fetches the delay between retries of a command.
|
java.lang.Long | getJobProcessInterval()
This method returns the job process interval in seconds.
|
void | performExecute()
This method executes all the scheduled actions to be executed in the batch at this point of time.
|
protected java.util.LinkedList<java.lang.Object[]> | retrieveScheduledActions()
This method retrieves the list of scheduled actions which are in active state and whose action date is less than current date + jobProcessInterval time.
|
void | setJobProcessInterval(java.lang.Long interval)
This method sets the job process interval in seconds.
|
public static final java.lang.String COPYRIGHT
public static final java.lang.String SCHEDULED_ACTIONS_QUERY
public void performExecute() throws ECException
The batch size is looked up from the request properties for this scheduler command. If the batch size is not specified, the default batch size is used SubscriptionSchedulerCmd.DEFAULT_BATCH_SIZE. The look ahead interval is obtained from the subscription configuration.
protected java.util.LinkedList<java.lang.Object[]> retrieveScheduledActions() throws ECApplicationException
protected int getDelayBetweenRetries(java.lang.Long scheduledActionId, SubscriptionScheduledActionCmd actionCmd)
public java.lang.Long getJobProcessInterval()
public void setJobProcessInterval(java.lang.Long interval)