Package org.openiam.esb.core.batch

Class BatchTaskScheduler

java.lang.Object

org.openiam.common.service.AbstractBaseService

org.openiam.esb.core.batch.BatchTaskScheduler

All Implemented Interfaces:

org.springframework.beans.factory.InitializingBean

@Component("batchTaskScheduler")
public class BatchTaskScheduler
extends AbstractBaseService
implements org.springframework.beans.factory.InitializingBean

Field Summary

Fields inherited from class org.openiam.common.service.AbstractBaseService

auditLogHelper, entityValidator, propertyValueSweeper

Constructor Summary

Constructors

Constructor	Description
BatchTaskScheduler()

Method Summary

Modifier and Type	Method	Description
void	afterPropertiesSet()
void	executeTasks()	Use redis lock to prevent another module / node (if any) to perform the same.
void	schedule(BatchTaskEntity entity)
void	sweep()

Methods inherited from class org.openiam.common.service.AbstractBaseService

getString, transaction, transaction, transaction

Methods inherited from class java.lang.Object

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

Constructor Detail

BatchTaskScheduler

public BatchTaskScheduler()

Method Detail

executeTasks

@Scheduled(fixedRateString="${org.openiam.batch.task.execute.time}")
public void executeTasks()
                  throws InterruptedException

Use redis lock to prevent another module / node (if any) to perform the same.

Throws:

InterruptedException

sweep

@Scheduled(fixedRateString="${org.openiam.batch.task.sweep.time}")
public void sweep()
           throws org.springframework.transaction.TransactionException,
                  InterruptedException

Throws:

org.springframework.transaction.TransactionException

InterruptedException

schedule

public void schedule(BatchTaskEntity entity)

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

Throws:

Exception