Package ca.uhn.fhir.jpa.cache

Class ResourceChangeListenerCacheRefresherImpl

java.lang.Object

ca.uhn.fhir.jpa.cache.ResourceChangeListenerCacheRefresherImpl

All Implemented Interfaces:

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

@Service
public class ResourceChangeListenerCacheRefresherImpl
extends Object
implements IResourceChangeListenerCacheRefresher, ca.uhn.fhir.jpa.model.sched.IHasScheduledJobs

This service refreshes the IResourceChangeListenerCache caches and notifies their listener when those caches change. Think of it like a Ferris Wheel that completes a full rotation once every 10 seconds. Every time a chair passes the bottom it checks to see if it's time to refresh that seat. If so, the Ferris Wheel stops, removes the riders, and loads a fresh cache for that chair, and calls the listener if any entries in the new cache are different from the last time that cache was loaded.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ResourceChangeListenerCacheRefresherImpl.Job

Constructor Summary

Constructors

Constructor	Description
ResourceChangeListenerCacheRefresherImpl()

Method Summary

Modifier and Type	Method	Description
ResourceChangeResult	forceRefreshAllCachesForUnitTest()
boolean	isStopping()
ResourceChangeResult	refreshCacheAndNotifyListener(IResourceChangeListenerCache theCache)	Refresh the cache in this entry and notify the entry's listener if the cache changed
ResourceChangeResult	refreshExpiredCachesAndNotifyListeners()	If the current time is past the next refresh time of the registered listener, then check if any of its resources have changed and notify the listener accordingly
void	scheduleJobs(ca.uhn.fhir.jpa.model.sched.ISchedulerService theSchedulerService)
void	setResourceChangeListenerRegistry(ResourceChangeListenerRegistryImpl theResourceChangeListenerRegistry)
void	setResourceVersionSvc(IResourceVersionSvc theResourceVersionSvc)
void	shutdown()
void	start()

Methods inherited from class java.lang.Object

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

Constructor Details

ResourceChangeListenerCacheRefresherImpl

public ResourceChangeListenerCacheRefresherImpl()

Method Details

scheduleJobs

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

Specified by:

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

refreshExpiredCachesAndNotifyListeners

public ResourceChangeResult refreshExpiredCachesAndNotifyListeners()

Description copied from interface: IResourceChangeListenerCacheRefresher

If the current time is past the next refresh time of the registered listener, then check if any of its resources have changed and notify the listener accordingly

Specified by:

refreshExpiredCachesAndNotifyListeners in interface IResourceChangeListenerCacheRefresher

Returns:

an aggregate of all changes sent to all listeners

forceRefreshAllCachesForUnitTest

public ResourceChangeResult forceRefreshAllCachesForUnitTest()

setResourceChangeListenerRegistry

public void setResourceChangeListenerRegistry(ResourceChangeListenerRegistryImpl theResourceChangeListenerRegistry)

setResourceVersionSvc

public void setResourceVersionSvc(IResourceVersionSvc theResourceVersionSvc)

start

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

Specified by:

start in interface IResourceChangeListenerCacheRefresher

shutdown

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

Specified by:

shutdown in interface IResourceChangeListenerCacheRefresher

isStopping

public boolean isStopping()

refreshCacheAndNotifyListener

public ResourceChangeResult refreshCacheAndNotifyListener(IResourceChangeListenerCache theCache)

Description copied from interface: IResourceChangeListenerCacheRefresher

Refresh the cache in this entry and notify the entry's listener if the cache changed

Specified by:

refreshCacheAndNotifyListener in interface IResourceChangeListenerCacheRefresher

Parameters:

theCache - the IResourceChangeListenerCache with the cache and the listener

Returns:

the number of resources that have been created, updated and deleted since the last time the cache was refreshed