Package ca.uhn.fhir.jpa.bulk.export.svc

Class BulkDataExportJobSchedulingHelperImpl

java.lang.Object

ca.uhn.fhir.jpa.bulk.export.svc.BulkDataExportJobSchedulingHelperImpl

All Implemented Interfaces:

IBulkDataExportJobSchedulingHelper, ca.uhn.fhir.jpa.model.sched.IHasScheduledJobs

public class BulkDataExportJobSchedulingHelperImpl
extends Object
implements IBulkDataExportJobSchedulingHelper, ca.uhn.fhir.jpa.model.sched.IHasScheduledJobs

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	BulkDataExportJobSchedulingHelperImpl.PurgeExpiredFilesJob

Constructor Summary

Constructors

Constructor	Description
BulkDataExportJobSchedulingHelperImpl(DaoRegistry theDaoRegistry, org.springframework.transaction.PlatformTransactionManager theTxManager, JpaStorageSettings theDaoConfig, BulkExportHelperService theBulkExportHelperSvc, IJobPersistence theJpaJobPersistence, org.springframework.transaction.support.TransactionTemplate theTxTemplate)

Method Summary

Modifier and Type	Method	Description
void	cancelAndPurgeAllJobs()
void	purgeExpiredFiles()	This method is called by the scheduler to run a pass of the generator
void	scheduleJobs(ca.uhn.fhir.jpa.model.sched.ISchedulerService theSchedulerService)
void	start()

Methods inherited from class java.lang.Object

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

Constructor Details

BulkDataExportJobSchedulingHelperImpl

public BulkDataExportJobSchedulingHelperImpl(DaoRegistry theDaoRegistry,
 org.springframework.transaction.PlatformTransactionManager theTxManager,
 JpaStorageSettings theDaoConfig,
 BulkExportHelperService theBulkExportHelperSvc,
 IJobPersistence theJpaJobPersistence,
 org.springframework.transaction.support.TransactionTemplate theTxTemplate)

Method Details

start

@PostConstruct
public void start()

scheduleJobs

public void scheduleJobs(ca.uhn.fhir.jpa.model.sched.ISchedulerService theSchedulerService)

Specified by:

scheduleJobs in interface ca.uhn.fhir.jpa.model.sched.IHasScheduledJobs

cancelAndPurgeAllJobs

@Transactional(propagation=NEVER)
public void cancelAndPurgeAllJobs()

Specified by:

cancelAndPurgeAllJobs in interface IBulkDataExportJobSchedulingHelper

purgeExpiredFiles

@Transactional(propagation=NEVER)
public void purgeExpiredFiles()

This method is called by the scheduler to run a pass of the generator

Specified by:

purgeExpiredFiles in interface IBulkDataExportJobSchedulingHelper