Package ca.uhn.fhir.jpa.term

Class TermDeferredStorageSvcImpl

java.lang.Object

ca.uhn.fhir.jpa.term.TermDeferredStorageSvcImpl

All Implemented Interfaces:

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

public class TermDeferredStorageSvcImpl
extends Object
implements ITermDeferredStorageSvc, ca.uhn.fhir.jpa.model.sched.IHasScheduledJobs

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TermDeferredStorageSvcImpl.Job

Field Summary

Fields

Modifier and Type	Field	Description
protected ITermCodeSystemDao	myCodeSystemDao
protected ITermCodeSystemVersionDao	myCodeSystemVersionDao
protected ITermConceptDao	myConceptDao
protected org.springframework.transaction.PlatformTransactionManager	myTransactionMgr

Constructor Summary

Constructors

Constructor	Description
TermDeferredStorageSvcImpl()

Method Summary

Modifier and Type	Method	Description
void	addConceptLinkToStorageQueue(TermConceptParentChildLink theConceptLink)
void	addConceptMapsToStorageQueue(List<org.hl7.fhir.r4.model.ConceptMap> theConceptMaps)
void	addConceptToStorageQueue(TermConcept theConcept)
void	addValueSetsToStorageQueue(List<org.hl7.fhir.r4.model.ValueSet> theValueSets)
void	clearDeferred()	This method is present only for unit tests, do not call from client code
void	deleteCodeSystemForResource(ResourceTable theCodeSystemToDelete)
void	deleteCodeSystemVersion(TermCodeSystemVersion theCodeSystemVersion)
void	disallowDeferredTaskTimeout()	Only to be used from tests - Disallow test timeouts on deferred tasks
boolean	isJobsExecuting()
boolean	isStorageQueueEmpty(boolean theIncludeExecutingJobs)	If you are calling this in a loop or something similar, consider the impact of setting theIncludeExecutingJobs to true.
void	logQueueForUnitTest()
void	notifyJobEnded(String theId)
void	saveAllDeferred()	This is mostly here for unit tests - Saves any and all deferred concepts and links
void	saveDeferred()
void	scheduleJobs(ca.uhn.fhir.jpa.model.sched.ISchedulerService theSchedulerService)
void	setProcessDeferred(boolean theProcessDeferred)	This is mostly for unit tests - we can disable processing of deferred concepts by changing this flag
String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface ca.uhn.fhir.jpa.term.api.ITermDeferredStorageSvc

isStorageQueueEmpty

Field Details

myConceptDao

@Autowired
protected ITermConceptDao myConceptDao

myCodeSystemDao

@Autowired
protected ITermCodeSystemDao myCodeSystemDao

myCodeSystemVersionDao

@Autowired
protected ITermCodeSystemVersionDao myCodeSystemVersionDao

myTransactionMgr

@Autowired
protected org.springframework.transaction.PlatformTransactionManager myTransactionMgr

Constructor Details

TermDeferredStorageSvcImpl

public TermDeferredStorageSvcImpl()

Method Details

addConceptToStorageQueue

public void addConceptToStorageQueue(TermConcept theConcept)

Specified by:

addConceptToStorageQueue in interface ITermDeferredStorageSvc

addConceptLinkToStorageQueue

public void addConceptLinkToStorageQueue(TermConceptParentChildLink theConceptLink)

Specified by:

addConceptLinkToStorageQueue in interface ITermDeferredStorageSvc

addConceptMapsToStorageQueue

public void addConceptMapsToStorageQueue(List<org.hl7.fhir.r4.model.ConceptMap> theConceptMaps)

Specified by:

addConceptMapsToStorageQueue in interface ITermDeferredStorageSvc

addValueSetsToStorageQueue

public void addValueSetsToStorageQueue(List<org.hl7.fhir.r4.model.ValueSet> theValueSets)

Specified by:

addValueSetsToStorageQueue in interface ITermDeferredStorageSvc

deleteCodeSystemForResource

public void deleteCodeSystemForResource(ResourceTable theCodeSystemToDelete)

Specified by:

deleteCodeSystemForResource in interface ITermDeferredStorageSvc

setProcessDeferred

public void setProcessDeferred(boolean theProcessDeferred)

Description copied from interface: ITermDeferredStorageSvc

This is mostly for unit tests - we can disable processing of deferred concepts by changing this flag

Specified by:

setProcessDeferred in interface ITermDeferredStorageSvc

clearDeferred

public void clearDeferred()

This method is present only for unit tests, do not call from client code

notifyJobEnded

public void notifyJobEnded(String theId)

Specified by:

notifyJobEnded in interface ITermDeferredStorageSvc

saveAllDeferred

public void saveAllDeferred()

Description copied from interface: ITermDeferredStorageSvc

This is mostly here for unit tests - Saves any and all deferred concepts and links

Specified by:

saveAllDeferred in interface ITermDeferredStorageSvc

saveDeferred

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

Specified by:

saveDeferred in interface ITermDeferredStorageSvc

isStorageQueueEmpty

public boolean isStorageQueueEmpty(boolean theIncludeExecutingJobs)

Description copied from interface: ITermDeferredStorageSvc

If you are calling this in a loop or something similar, consider the impact of setting theIncludeExecutingJobs to true. When that parameter is set to true, each call to this method results in a database lookup!

Specified by:

isStorageQueueEmpty in interface ITermDeferredStorageSvc

isJobsExecuting

public boolean isJobsExecuting()

Specified by:

isJobsExecuting in interface ITermDeferredStorageSvc

disallowDeferredTaskTimeout

public void disallowDeferredTaskTimeout()

Description copied from interface: ITermDeferredStorageSvc

Only to be used from tests - Disallow test timeouts on deferred tasks

Specified by:

disallowDeferredTaskTimeout in interface ITermDeferredStorageSvc

logQueueForUnitTest

public void logQueueForUnitTest()

Specified by:

logQueueForUnitTest in interface ITermDeferredStorageSvc

deleteCodeSystemVersion

public void deleteCodeSystemVersion(TermCodeSystemVersion theCodeSystemVersion)

Specified by:

deleteCodeSystemVersion in interface ITermDeferredStorageSvc

scheduleJobs

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

Specified by:

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

toString

public String toString()

Overrides:

toString in class Object