Package ca.uhn.fhir.jpa.cache

Class ResourceChangeListenerCache

java.lang.Object

ca.uhn.fhir.jpa.cache.ResourceChangeListenerCache

All Implemented Interfaces:

IResourceChangeListenerCache

@Component
@Scope("prototype")
public class ResourceChangeListenerCache
extends Object
implements IResourceChangeListenerCache

Constructor Summary

Constructors

Constructor	Description
ResourceChangeListenerCache(String theResourceName, IResourceChangeListener theResourceChangeListener, SearchParameterMap theSearchParameterMap, long theRemoteRefreshIntervalMs)

Method Summary

Modifier and Type	Method	Description
void	clearForUnitTest()
ResourceChangeResult	forceRefresh()	Request that a cache be refreshed now, in the current thread
Instant	getNextRefreshTime()
IResourceChangeListener	getResourceChangeListener()
String	getResourceName()
ResourceVersionCache	getResourceVersionCache()
SearchParameterMap	getSearchParameterMap()
boolean	isInitialized()
protected boolean	isTimeToRefresh()
boolean	matches(org.hl7.fhir.instance.model.api.IBaseResource theResource)
ResourceChangeResult	refreshCacheIfNecessary()	If nextRefreshTime is in the past, then update the cache with the current repository contents and notify its listener of any changes
ResourceChangeResult	refreshCacheWithRetry()
void	requestRefresh()	Request that the cache be refreshed at the next convenient time (in a different thread)
void	requestRefreshIfWatching(org.hl7.fhir.instance.model.api.IBaseResource theResource)	Refresh the cache if theResource matches our SearchParameterMap
ResourceChangeListenerCache	setInitialized(boolean theInitialized)
static void	setNowForUnitTests(String theTime)
void	setResourceChangeListenerCacheRefresher(IResourceChangeListenerCacheRefresher theResourceChangeListenerCacheRefresher)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

ResourceChangeListenerCache

public ResourceChangeListenerCache(String theResourceName,
 IResourceChangeListener theResourceChangeListener,
 SearchParameterMap theSearchParameterMap,
 long theRemoteRefreshIntervalMs)

Method Details

requestRefresh

public void requestRefresh()

Request that the cache be refreshed at the next convenient time (in a different thread)

Specified by:

requestRefresh in interface IResourceChangeListenerCache

forceRefresh

public ResourceChangeResult forceRefresh()

Request that a cache be refreshed now, in the current thread

Specified by:

forceRefresh in interface IResourceChangeListenerCache

Returns:

counts of detected resource creates, updates and deletes

requestRefreshIfWatching

public void requestRefreshIfWatching(org.hl7.fhir.instance.model.api.IBaseResource theResource)

Refresh the cache if theResource matches our SearchParameterMap

Parameters:

theResource -

matches

public boolean matches(org.hl7.fhir.instance.model.api.IBaseResource theResource)

refreshCacheIfNecessary

public ResourceChangeResult refreshCacheIfNecessary()

Description copied from interface: IResourceChangeListenerCache

If nextRefreshTime is in the past, then update the cache with the current repository contents and notify its listener of any changes

Specified by:

refreshCacheIfNecessary in interface IResourceChangeListenerCache

Returns:

counts of detected resource creates, updates and deletes

isTimeToRefresh

protected boolean isTimeToRefresh()

refreshCacheWithRetry

public ResourceChangeResult refreshCacheWithRetry()

setResourceChangeListenerCacheRefresher

public void setResourceChangeListenerCacheRefresher(IResourceChangeListenerCacheRefresher theResourceChangeListenerCacheRefresher)

getNextRefreshTime

public Instant getNextRefreshTime()

Specified by:

getNextRefreshTime in interface IResourceChangeListenerCache

Returns:

the next scheduled time the cache will search the repository, update its cache and notify its listener of any changes

getSearchParameterMap

public SearchParameterMap getSearchParameterMap()

Specified by:

getSearchParameterMap in interface IResourceChangeListenerCache

Returns:

the search parameter map the listener was registered with

isInitialized

public boolean isInitialized()

Specified by:

isInitialized in interface IResourceChangeListenerCache

Returns:

whether the cache has been initialized. (If not, the cache will be empty.)

setInitialized

public ResourceChangeListenerCache setInitialized(boolean theInitialized)

getResourceName

public String getResourceName()

Specified by:

getResourceName in interface IResourceChangeListenerCache

Returns:

the name of the resource type the listener was registered with

getResourceVersionCache

public ResourceVersionCache getResourceVersionCache()

getResourceChangeListener

public IResourceChangeListener getResourceChangeListener()

setNowForUnitTests

public static void setNowForUnitTests(String theTime)

Parameters:

theTime - has format like "12:34:56" i.e. HH:MM:SS

clearForUnitTest

public void clearForUnitTest()

toString

public String toString()

Overrides:

toString in class Object