public class IndexingPeriodicService extends SchedulableService implements atg.nucleus.PostStartupAction
Created: April 21 2005
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
CLASS_VERSION
Class version string
|
mJobId
SERVICE_INFO_KEY
DEFAULT_LOG_TRACE_STATUS
DEFAULT_LOG_DEBUG_STATUS, DEFAULT_LOG_ERROR_STATUS, DEFAULT_LOG_INFO_STATUS, DEFAULT_LOG_WARNING_STATUS
Constructor and Description |
---|
IndexingPeriodicService() |
Modifier and Type | Method and Description |
---|---|
void |
checkForExpiredConfigurationClaims()
Look for expirations that have expired.
|
void |
doStartService()
The default implementation is to just start our scheduled
job.
|
long |
getCheckExpiredConfigurationClaimsIntervalMSecs()
The minimum interval in milliseconds between checks for expired configuration claims.
|
ConfigStatePersister |
getConfigStatePersister()
Get the configuration state persister.
|
IncrementalLoader |
getIncrementalLoader()
Get the incremental loader to use.
|
java.util.List |
getIncrementalLoaders() |
boolean |
isEnabled()
Return whether this service is enabled.
|
boolean |
isPostStartup()
If true, Nucleus has called performAction()
|
protected boolean |
needsIncrementalUpdate(ConfigStatePersister.ConfigState pConfigState,
IndexingOutputConfig pConfig)
Whether the specified configuration needs an incremental update
based on the last update indexed times.
|
void |
performAction()
Implementation of PostStartupAction interface.
|
void |
performScheduledTask()
Perform our scheduled task.
|
void |
performScheduledTask(Scheduler pScheduler,
ScheduledJob pJob)
Called by the scheduler when it is time for this service to perform its
function.
|
void |
scanForIncrementalUpdates()
Look for configurations to claim.
|
protected void |
scanForIncrementalUpdates(IncrementalLoader pLoader) |
void |
setCheckExpiredConfigurationClaimsIntervalMSecs(long pCheckExpiredConfigurationClaimsIntervalMSecs)
Set the minimum interval in milliseconds between checks for expired configuration claims.
|
void |
setConfigStatePersister(ConfigStatePersister pConfigStatePersister)
Set the configuration state persister.
|
void |
setEnabled(boolean pEnabled)
Set whether this service is enabled.
|
void |
setIncrementalLoader(IncrementalLoader pIncrementalLoader)
Set the incremental loader to use.
|
void |
setIncrementalLoaders(java.util.List pLoaders) |
void |
setPostStartup(boolean pPostStartup)
If true, Nucleus has called performAction()
|
doStopService, getJobDescription, getJobId, getJobName, getSchedule, getScheduler, getThreadMethod, getThreadMethodString, isTransactional, setJobDescription, setJobName, setSchedule, setScheduler, setThreadMethod, setThreadMethodString, setTransactional, startScheduledJob, stopScheduledJob
addLogListener, createAdminServlet, getAbsoluteName, getAdminServlet, getAdminServletOutputStreamEncoding, getLoggingForVlogging, getLogListenerCount, getLogListeners, getName, getNameContext, getNucleus, getRoot, getServiceConfiguration, getServiceInfo, isAdminServletUseServletOutputStream, isLoggingDebug, isLoggingError, isLoggingInfo, isLoggingTrace, isLoggingWarning, isRunning, logDebug, logDebug, logDebug, logError, logError, logError, logInfo, logInfo, logInfo, logTrace, logTrace, logTrace, logWarning, logWarning, logWarning, nameContextElementBound, nameContextElementUnbound, removeLogListener, reResolveThis, resolveName, resolveName, resolveName, resolveName, sendLogEvent, setAdminServletOutputStreamEncoding, setAdminServletUseServletOutputStream, setLoggingDebug, setLoggingError, setLoggingInfo, setLoggingTrace, setLoggingWarning, setNucleus, setServiceInfo, startService, stopService, toString
vlogDebug, vlogDebug, vlogDebug, vlogDebug, vlogDebugTrace, vlogError, vlogError, vlogError, vlogError, vlogInfo, vlogInfo, vlogInfo, vlogInfo, vlogTrace, vlogTrace, vlogTrace, vlogTrace, vlogWarning, vlogWarning, vlogWarning, vlogWarning
public void setConfigStatePersister(ConfigStatePersister pConfigStatePersister)
public ConfigStatePersister getConfigStatePersister()
public void setEnabled(boolean pEnabled)
public boolean isEnabled()
public boolean isPostStartup()
public void setPostStartup(boolean pPostStartup)
public void setIncrementalLoader(IncrementalLoader pIncrementalLoader)
public IncrementalLoader getIncrementalLoader()
public java.util.List getIncrementalLoaders()
public void setIncrementalLoaders(java.util.List pLoaders)
public void setCheckExpiredConfigurationClaimsIntervalMSecs(long pCheckExpiredConfigurationClaimsIntervalMSecs)
public long getCheckExpiredConfigurationClaimsIntervalMSecs()
public void doStartService() throws ServiceException
doStartService
in class SchedulableService
ServiceException
- if an error occurred during the operationpublic void performAction()
performAction
in interface atg.nucleus.PostStartupAction
public void performScheduledTask(Scheduler pScheduler, ScheduledJob pJob)
performScheduledTask
in interface Schedulable
performScheduledTask
in class SchedulableService
pScheduler
- the scheduler managing this jobpJob
- the scheduled job associated with this servicepublic void performScheduledTask() throws IndexingException
IndexingException
public void checkForExpiredConfigurationClaims() throws IndexingException
IndexingException
public void scanForIncrementalUpdates()
protected void scanForIncrementalUpdates(IncrementalLoader pLoader)
protected boolean needsIncrementalUpdate(ConfigStatePersister.ConfigState pConfigState, IndexingOutputConfig pConfig)
pConfigState
- the configuration state to checkpConfig
- the configuration.