Package ca.uhn.fhir.cache

Class BaseResourceCacheSynchronizer

java.lang.Object

ca.uhn.fhir.cache.BaseResourceCacheSynchronizer

All Implemented Interfaces:

IResourceChangeListener

public abstract class BaseResourceCacheSynchronizer
extends Object
implements IResourceChangeListener

Field Summary

Fields

Modifier and Type	Field	Description
static final int	MAX_RETRIES
static final long	REFRESH_INTERVAL

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	BaseResourceCacheSynchronizer(String theResourceName)
protected	BaseResourceCacheSynchronizer(String theResourceName, IResourceChangeListenerRegistry theResourceChangeListenerRegistry, DaoRegistry theDaoRegistry)

Method Summary

Modifier and Type	Method	Description
void	acquireSemaphoreForUnitTest()
int	doSyncResourcesForUnitTest()
protected abstract SearchParameterMap	getSearchParameterMap()
void	handleChange(IResourceChangeEvent theResourceChangeEvent)
void	handleInit(Collection<org.hl7.fhir.instance.model.api.IIdType> theResourceIds)
protected abstract void	handleInit(List<org.hl7.fhir.instance.model.api.IBaseResource> resourceList)
void	registerListener()	This method performs a search in the DB, so use the ContextStartedEvent to ensure that it runs after the database initializer
void	shutdown()
void	start()
void	syncDatabaseToCache()	Read the existing resources from the database
protected abstract int	syncResourcesIntoCache(List<org.hl7.fhir.instance.model.api.IBaseResource> resourceList)
void	unregisterListener()

Methods inherited from class java.lang.Object

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

Field Details

MAX_RETRIES

public static final int MAX_RETRIES

See Also:

• Constant Field Values

REFRESH_INTERVAL

public static final long REFRESH_INTERVAL

See Also:

• Constant Field Values

Constructor Details

BaseResourceCacheSynchronizer

protected BaseResourceCacheSynchronizer(String theResourceName)

BaseResourceCacheSynchronizer

protected BaseResourceCacheSynchronizer(String theResourceName,
 IResourceChangeListenerRegistry theResourceChangeListenerRegistry,
 DaoRegistry theDaoRegistry)

Method Details

registerListener

@EventListener(classes=org.springframework.context.event.ContextRefreshedEvent.class)
@Order(310)
public void registerListener()

This method performs a search in the DB, so use the ContextStartedEvent to ensure that it runs after the database initializer

unregisterListener

@PreDestroy
public void unregisterListener()

syncDatabaseToCache

public void syncDatabaseToCache()

Read the existing resources from the database

acquireSemaphoreForUnitTest

public void acquireSemaphoreForUnitTest()
                                 throws InterruptedException

Throws:

InterruptedException

doSyncResourcesForUnitTest

public int doSyncResourcesForUnitTest()

syncResourcesIntoCache

protected abstract int syncResourcesIntoCache(List<org.hl7.fhir.instance.model.api.IBaseResource> resourceList)

start

@EventListener(org.springframework.context.event.ContextRefreshedEvent.class)
public void start()

shutdown

@EventListener(org.springframework.context.event.ContextClosedEvent.class)
public void shutdown()

handleInit

public void handleInit(Collection<org.hl7.fhir.instance.model.api.IIdType> theResourceIds)

Specified by:

handleInit in interface IResourceChangeListener

handleInit

protected abstract void handleInit(List<org.hl7.fhir.instance.model.api.IBaseResource> resourceList)

handleChange

public void handleChange(IResourceChangeEvent theResourceChangeEvent)

Specified by:

handleChange in interface IResourceChangeListener

getSearchParameterMap

@Nonnull
protected abstract SearchParameterMap getSearchParameterMap()