public class SubscriptionExpireScheduledActionImpl extends AbstractSubscriptionScheduledActionCmdImpl
Modifier and Type | Field and Description |
---|---|
static java.lang.String | COPYRIGHT
IBM Copyright notice field.
|
Constructor and Description |
---|
SubscriptionExpireScheduledActionImpl() |
Modifier and Type | Method and Description |
---|---|
protected void | deleteSubscriptionJobs()
This method invokes the getPhysicalDataContainer method to fetch the subscription record along with the future unprocessed jobs to be deleted.
|
protected void | expireSubscription()
This method is used to expire a subscription after its end date.
|
int | getDelayBetweenRetries()
This method sets a static delay of 0 seconds for retries
|
protected java.lang.Integer | getFinalStateForSubscription()
This will help the scheduler to get the final state of the subscription.
|
protected java.lang.Integer | getInitialState()
This method will implement the logic to return the initial transient state of the scheduled action
|
protected int | getMaximumNumberOfRetriesForState(java.lang.Integer state)
This method will help the scheduler to get the maximum number of retries for the state.
|
protected PhysicalDataContainer | getPhysicalDataContainer()
This method initializes the physical data container with the subscription record and the set of unprocessed scheduled jobs whose action date > expire date of the given subscription ID.
|
protected Subscrschjobs | getScheduledJob()
This method returns the scheduled action job that is currently being processed
|
protected void | handleStateRetry(AbstractSubscriptionScheduledActionCmdImpl.StackEntry stateToRetry)
This method handles the retry for the given state.
|
protected boolean | isExceptionRetriable(java.lang.Exception exceptionToCheck)
This method will help the scheduler to know whether an exception can be re tried.
|
protected boolean | isStateValid(Subscription phySubscription)
This method is used to find out if the state of the subscription is valid for any further processing If the state is either expired or cancelled, no further processing is done.
|
protected void | processSubscriptionState(AbstractSubscriptionScheduledActionCmdImpl.StackEntry entry)
This method invokes the deleteSubscriptionJobs to delete all the future unprocessed jobs and then invokes the expireSubscription to update the subscription status.
|
protected void | recoverState(AbstractSubscriptionScheduledActionCmdImpl.StackEntry completedState)
This method will implement the logic for recovering from the given state in case of exceptions.
|
public static final java.lang.String COPYRIGHT
public SubscriptionExpireScheduledActionImpl()
protected PhysicalDataContainer getPhysicalDataContainer()
protected Subscrschjobs getScheduledJob()
protected java.lang.Integer getFinalStateForSubscription()
protected int getMaximumNumberOfRetriesForState(java.lang.Integer state)
protected void handleStateRetry(AbstractSubscriptionScheduledActionCmdImpl.StackEntry stateToRetry)
protected boolean isExceptionRetriable(java.lang.Exception exceptionToCheck)
protected void processSubscriptionState(AbstractSubscriptionScheduledActionCmdImpl.StackEntry entry)
protected boolean isStateValid(Subscription phySubscription)
protected void deleteSubscriptionJobs()
protected void expireSubscription()
protected void recoverState(AbstractSubscriptionScheduledActionCmdImpl.StackEntry completedState)
protected java.lang.Integer getInitialState()
public int getDelayBetweenRetries()