Package ca.uhn.fhir.jpa.subscription.match.registry

Class SubscriptionLoader

java.lang.Object

ca.uhn.fhir.cache.BaseResourceCacheSynchronizer

ca.uhn.fhir.jpa.subscription.match.registry.SubscriptionLoader

All Implemented Interfaces:

IResourceChangeListener

public class SubscriptionLoader
extends BaseResourceCacheSynchronizer

Field Summary

Fields inherited from class ca.uhn.fhir.cache.BaseResourceCacheSynchronizer

MAX_RETRIES, mySearchParamRegistry, REFRESH_INTERVAL

Constructor Summary

Constructors

Constructor	Description
SubscriptionLoader()	Constructor

Method Summary

Modifier and Type	Method	Description
int	doSyncSubscriptionsForUnitTest()
protected SearchParameterMap	getSearchParameterMap()
protected void	handleInit(List<org.hl7.fhir.instance.model.api.IBaseResource> resourceList)
protected int	syncResourcesIntoCache(List<org.hl7.fhir.instance.model.api.IBaseResource> resourceList)
void	syncSubscriptions()

Methods inherited from class ca.uhn.fhir.cache.BaseResourceCacheSynchronizer

acquireSemaphoreForUnitTest, doSyncResourcessForUnitTest, handleChange, handleInit, registerListener, shutdown, start, syncDatabaseToCache, unregisterListener

Methods inherited from class java.lang.Object

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

Constructor Details

SubscriptionLoader

public SubscriptionLoader()

Constructor

Method Details

doSyncSubscriptionsForUnitTest

public int doSyncSubscriptionsForUnitTest()

getSearchParameterMap

@Nonnull
protected SearchParameterMap getSearchParameterMap()

Specified by:

getSearchParameterMap in class BaseResourceCacheSynchronizer

handleInit

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

Specified by:

handleInit in class BaseResourceCacheSynchronizer

syncResourcesIntoCache

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

Specified by:

syncResourcesIntoCache in class BaseResourceCacheSynchronizer

syncSubscriptions

public void syncSubscriptions()