Package org.ikasan.housekeeping

Class HousekeepingJobImpl

java.lang.Object

org.ikasan.housekeeping.HousekeepingJobImpl

All Implemented Interfaces:

org.ikasan.spec.housekeeping.HousekeepingJob, org.ikasan.spec.monitor.MonitorSubject, org.quartz.Job

@DisallowConcurrentExecution
public class HousekeepingJobImpl
extends java.lang.Object
implements org.ikasan.spec.housekeeping.HousekeepingJob, org.ikasan.spec.monitor.MonitorSubject

Created by Ikasan Development Team on 09/07/2019.

Field Summary

Fields inherited from interface org.ikasan.spec.housekeeping.HousekeepingJob

CRON_EXPRESSION, DEFAULT_BATCH_DELETE_SIZE, DEFAULT_CRON_EXPRESSION, DEFAULT_TRANSACTION_DELETE_SIZE, ENABLED, HOUSE_KEEPING_BATCH_SIZE, TRANSACTION_BATCH_SIZE

Constructor Summary

Constructors

Constructor	Description
HousekeepingJobImpl(java.lang.String jobName, org.ikasan.spec.housekeeping.HousekeepService houseKeepService, org.springframework.core.env.Environment environment)

Method Summary

Modifier and Type	Method	Description
void	execute(org.quartz.JobExecutionContext jobExecutionContext)
java.lang.Integer	getBatchDeleteSize()
java.lang.String	getCronExpression()
org.springframework.core.env.Environment	getEnvironment()
java.lang.String	getExecutionErrorMessage()
java.lang.String	getJobName()
java.lang.Boolean	getLastExecutionSuccessful()
java.lang.Integer	getTransactionDeleteSize()
void	init()
java.lang.Boolean	isEnabled()
java.lang.Boolean	isInitialised()
void	save()
void	setBatchDeleteSize(java.lang.Integer batchDeleteSize)
void	setCronExpression(java.lang.String cronExpression)
void	setEnabled(java.lang.Boolean enabled)
void	setInitialised(java.lang.Boolean initialised)
void	setMonitor(org.ikasan.spec.monitor.Monitor monitor)
void	setTransactionDeleteSize(java.lang.Integer transactionDeleteSize)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HousekeepingJobImpl

public HousekeepingJobImpl(java.lang.String jobName,
                           org.ikasan.spec.housekeeping.HousekeepService houseKeepService,
                           org.springframework.core.env.Environment environment)

Method Detail

init

public void init()

Specified by:

init in interface org.ikasan.spec.housekeeping.HousekeepingJob

save

public void save()

Specified by:

save in interface org.ikasan.spec.housekeeping.HousekeepingJob

execute

public void execute(org.quartz.JobExecutionContext jobExecutionContext)
             throws org.quartz.JobExecutionException

Specified by:

execute in interface org.quartz.Job

Throws:

org.quartz.JobExecutionException

setCronExpression

public void setCronExpression(java.lang.String cronExpression)

Specified by:

setCronExpression in interface org.ikasan.spec.housekeeping.HousekeepingJob

getCronExpression

public java.lang.String getCronExpression()

Specified by:

getCronExpression in interface org.ikasan.spec.housekeeping.HousekeepingJob

setMonitor

public void setMonitor(org.ikasan.spec.monitor.Monitor monitor)

Specified by:

setMonitor in interface org.ikasan.spec.monitor.MonitorSubject

getEnvironment

public org.springframework.core.env.Environment getEnvironment()

getJobName

public java.lang.String getJobName()

Specified by:

getJobName in interface org.ikasan.spec.housekeeping.HousekeepingJob

getBatchDeleteSize

public java.lang.Integer getBatchDeleteSize()

Specified by:

getBatchDeleteSize in interface org.ikasan.spec.housekeeping.HousekeepingJob

getTransactionDeleteSize

public java.lang.Integer getTransactionDeleteSize()

Specified by:

getTransactionDeleteSize in interface org.ikasan.spec.housekeeping.HousekeepingJob

setBatchDeleteSize

public void setBatchDeleteSize(java.lang.Integer batchDeleteSize)

Specified by:

setBatchDeleteSize in interface org.ikasan.spec.housekeeping.HousekeepingJob

setTransactionDeleteSize

public void setTransactionDeleteSize(java.lang.Integer transactionDeleteSize)

Specified by:

setTransactionDeleteSize in interface org.ikasan.spec.housekeeping.HousekeepingJob

isEnabled

public java.lang.Boolean isEnabled()

Specified by:

isEnabled in interface org.ikasan.spec.housekeeping.HousekeepingJob

setEnabled

public void setEnabled(java.lang.Boolean enabled)

Specified by:

setEnabled in interface org.ikasan.spec.housekeeping.HousekeepingJob

getLastExecutionSuccessful

public java.lang.Boolean getLastExecutionSuccessful()

Specified by:

getLastExecutionSuccessful in interface org.ikasan.spec.housekeeping.HousekeepingJob

getExecutionErrorMessage

public java.lang.String getExecutionErrorMessage()

Specified by:

getExecutionErrorMessage in interface org.ikasan.spec.housekeeping.HousekeepingJob

isInitialised

public java.lang.Boolean isInitialised()

Specified by:

isInitialised in interface org.ikasan.spec.housekeeping.HousekeepingJob

setInitialised

public void setInitialised(java.lang.Boolean initialised)

Specified by:

setInitialised in interface org.ikasan.spec.housekeeping.HousekeepingJob