Package org.frankframework.scheduler.job
Class CleanupDatabaseJob
java.lang.Object
org.frankframework.core.TransactionAttributes
org.frankframework.scheduler.JobDef
org.frankframework.scheduler.job.CleanupDatabaseJob
- All Implemented Interfaces:
HasTransactionAttribute
,IConfigurable
,IConfigurationAware
,INamedObject
,IScopeProvider
,IJob
,org.springframework.beans.factory.Aware
,org.springframework.context.ApplicationContextAware
-
Field Summary
Fields inherited from class org.frankframework.core.TransactionAttributes
log
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionboolean
Called before executeJob to prepare resources for executeJob method.void
execute()
Actual implementation of theIJob
.Locate all Lockers, and find out which datasources are used.protected List<org.frankframework.scheduler.job.CleanupDatabaseJob.MessageLogObject>
getCleanUpIbisstoreQuery
(String tableName, String keyField, String typeField, String expiryDateField, int maxRows, Dbms dbmsName) int
void
setQueryTimeout
(int i) The number of seconds the database driver will wait for a statement to execute.Methods inherited from class org.frankframework.scheduler.JobDef
configure, decrementCountThreads, executeJob, getApplicationContext, getConfigurationClassLoader, getCronExpression, getDescription, getIbisManager, getInterval, getJobDetail, getJobGroup, getLocker, getLogPrefix, getMessageKeeper, getName, getNumThreads, incrementCountThreads, isConfigured, setApplicationContext, setConfigurationMetrics, setCronExpression, setDescription, setInterval, setJobGroup, setLocker, setMessageKeeperSize, setName, setNumThreads, toString
Methods inherited from class org.frankframework.core.TransactionAttributes
configureTransactionAttributes, getTransactionAttribute, getTransactionTimeout, getTxDef, isTransacted, isTransacted, setTransacted, setTransactionAttribute, setTransactionTimeout
-
Constructor Details
-
CleanupDatabaseJob
public CleanupDatabaseJob()
-
-
Method Details
-
beforeExecuteJob
public boolean beforeExecuteJob()Description copied from class:JobDef
Called before executeJob to prepare resources for executeJob method. Returns false if job does not need to run- Overrides:
beforeExecuteJob
in classJobDef
-
execute
public void execute()Description copied from interface:IJob
Actual implementation of theIJob
. Is wrapped around aLocker
andexceptions
will be managed automatically. -
getAllLockerDatasourceNames
Locate all Lockers, and find out which datasources are used.- Returns:
- distinct list of all datasourceNames used by lockers
-
getAllMessageLogs
protected List<org.frankframework.scheduler.job.CleanupDatabaseJob.MessageLogObject> getAllMessageLogs() -
setQueryTimeout
public void setQueryTimeout(int i) The number of seconds the database driver will wait for a statement to execute. If the limit is exceeded, a TimeoutException is thrown. 0 means no timeout- Default value
- 0
-
getCleanUpIbisstoreQuery
-
getQueryTimeout
public int getQueryTimeout()
-