Package org.molgenis.data.index.job

Class IndexJobSchedulerImpl

java.lang.Object

org.molgenis.data.index.job.IndexJobSchedulerImpl

All Implemented Interfaces:

IndexJobScheduler

public class IndexJobSchedulerImpl
extends Object
implements IndexJobScheduler

Constructor Summary

Constructors

Constructor	Description
IndexJobSchedulerImpl(DataService dataService, IndexJobExecutionFactory indexJobExecutionFactory, JobExecutor jobExecutor)

Method Summary

Modifier and Type	Method	Description
void	cleanupJobExecutions()	Cleans up successful IndexJobExecutions that finished longer than five minutes ago.
void	scheduleIndexJob(String transactionId)	Schedules a job to rebuild the index for all changes made in the context of a specific transaction.
void	waitForAllIndicesStable()
void	waitForIndexToBeStableIncludingReferences(EntityType entityType)

Methods inherited from class java.lang.Object

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

Constructor Detail

IndexJobSchedulerImpl

public IndexJobSchedulerImpl(DataService dataService,
                             IndexJobExecutionFactory indexJobExecutionFactory,
                             JobExecutor jobExecutor)

Method Detail

scheduleIndexJob

public void scheduleIndexJob(String transactionId)

Description copied from interface: IndexJobScheduler

Schedules a job to rebuild the index for all changes made in the context of a specific transaction. Does nothing if no IndexActionJob exists for this transactionId.

Specified by:

scheduleIndexJob in interface IndexJobScheduler

Parameters:

transactionId - the ID of the transaction.

waitForAllIndicesStable

public void waitForAllIndicesStable()
                             throws InterruptedException

Specified by:

waitForAllIndicesStable in interface IndexJobScheduler

Throws:

InterruptedException

waitForIndexToBeStableIncludingReferences

public void waitForIndexToBeStableIncludingReferences(EntityType entityType)
                                               throws InterruptedException

Specified by:

waitForIndexToBeStableIncludingReferences in interface IndexJobScheduler

Throws:

InterruptedException

cleanupJobExecutions

@Scheduled(initialDelay=60000L,
           fixedRate=300000L)
public void cleanupJobExecutions()

Cleans up successful IndexJobExecutions that finished longer than five minutes ago. delay for a minute to allow the transaction manager to become available

Specified by:

cleanupJobExecutions in interface IndexJobScheduler