Package ca.uhn.fhir.cache

Class BaseResourceCacheSynchronizer

java.lang.Object

ca.uhn.fhir.cache.BaseResourceCacheSynchronizer

All Implemented Interfaces:

IResourceChangeListener, ca.uhn.fhir.rest.server.util.IResourceRepositoryCache

public abstract class BaseResourceCacheSynchronizer
extends Object
implements IResourceChangeListener, ca.uhn.fhir.rest.server.util.IResourceRepositoryCache

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()
void	forceRefresh()
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	requestRefresh()
void	setMaxRetries(Integer theMaxRetries)
void	shutdown()
void	start()
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()

requestRefresh

public void requestRefresh()

Specified by:

requestRefresh in interface ca.uhn.fhir.rest.server.util.IResourceRepositoryCache

forceRefresh

public void forceRefresh()

Specified by:

forceRefresh in interface ca.uhn.fhir.rest.server.util.IResourceRepositoryCache

acquireSemaphoreForUnitTest

public void acquireSemaphoreForUnitTest()
                                 throws InterruptedException

Throws:

InterruptedException

doSyncResourcesForUnitTest

public int doSyncResourcesForUnitTest()

setMaxRetries

public void setMaxRetries(Integer theMaxRetries)

syncResourcesIntoCache

protected abstract int syncResourcesIntoCache(@Nonnull
 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(@Nonnull
 Collection<org.hl7.fhir.instance.model.api.IIdType> theResourceIds)

Specified by:

handleInit in interface IResourceChangeListener

handleInit

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

handleChange

public void handleChange(@Nonnull
 IResourceChangeEvent theResourceChangeEvent)

Specified by:

handleChange in interface IResourceChangeListener

getSearchParameterMap

@Nonnull
protected abstract SearchParameterMap getSearchParameterMap()