public class FhirResourceDaoSubscriptionDstu2 extends FhirResourceDaoDstu2<Subscription> implements IFhirResourceDaoSubscription<Subscription>
myPlatformTransactionManager, myResourceIndexedSearchParamUriDao, myResourceTableDao, mySearchDao, mySearchResultDao, myTerminologySvcINDEX_STATUS_INDEXED, INDEX_STATUS_INDEXING_FAILED, myEntityManager, myForcedIdDao, NS_JPA_PROFILE, OO_SEVERITY_ERROR, OO_SEVERITY_INFO, OO_SEVERITY_WARN, UCUM_NSRESOURCE_PID| Constructor and Description |
|---|
FhirResourceDaoSubscriptionDstu2() |
| Modifier and Type | Method and Description |
|---|---|
Long |
getSubscriptionTablePidForSubscriptionResource(IIdType theId) |
List<IBaseResource> |
getUndeliveredResourcesAndPurge(Long theSubscriptionPid) |
int |
pollForNewUndeliveredResources() |
void |
pollForNewUndeliveredResourcesScheduler() |
protected void |
postPersist(ResourceTable theEntity,
Subscription theSubscription)
Subclasses may override to provide behaviour.
|
void |
purgeInactiveSubscriptions() |
protected ResourceTable |
updateEntity(IBaseResource theResource,
ResourceTable theEntity,
Date theDeletedTimestampOrNull,
boolean thePerformIndexing,
boolean theUpdateVersion,
Date theUpdateTime) |
protected void |
validateResourceForStorage(Subscription theResource,
ResourceTable theEntityToSave)
This method is invoked immediately before storing a new resource, or an update to an existing resource to allow the DAO to ensure that it is valid for persistence.
|
createOperationOutcome, getIncludeValues, validateaddTag, create, create, create, create, create, createErrorOperationOutcome, createInfoOperationOutcome, delete, delete, delete, deleteByUrl, deleteByUrl, detectSearchDaoDisabled, getAllResourceTags, getResourceName, getResourceType, getTags, history, history, metaAddOperation, metaDeleteOperation, metaGetOperation, metaGetOperation, patch, postConstruct, preDelete, preProcessResourceForStorage, processMatchUrl, read, read, readEntity, readEntity, readEntityLatestVersion, reindex, removeTag, removeTag, search, search, search, searchForIds, searchForIds, searchForIdsWithAndOr, setResourceType, setSecondaryPrimaryKeyParamName, toMetaDt, translateRawParameters, update, update, update, update, update, validateOkToDeleteclearRequestAsProcessingSubRequest, createForcedIdIfNeeded, extractResourceLinks, extractSearchParamCoords, extractSearchParamDates, extractSearchParamNumber, extractSearchParamQuantity, extractSearchParamStrings, extractSearchParamTokens, extractSearchParamUri, getConfig, getContext, getContext, getDao, getSearchParamByName, getSearchParamsByResourceType, getTag, getTags, history, injectDependenciesIntoBundleProvider, isLogicalReference, isValidPid, markRequestAsProcessingSubRequest, newInstanceAnd, newInstanceType, normalizeString, notifyInterceptors, parseContentTextIntoWords, populateFullTextFields, populateResourceIntoEntity, postUpdate, processMatchUrl, setConfig, setContext, setEntityManager, setPlatformTransactionManager, shouldDroppedTagBeRemovedOnUpdate, toEntity, toResource, toResource, toResourceName, toResourceName, translateForcedIdToPid, translateForcedIdToPid, translateForcedIdToPids, translateMatchUrl, translateMatchUrl, translatePidIdToForcedId, updateEntity, validateDeleteConflictsEmptyOrThrowException, validateResourceTypeclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitaddTag, create, create, create, create, create, delete, delete, delete, deleteByUrl, deleteByUrl, getAllResourceTags, getResourceType, getTags, history, history, metaAddOperation, metaDeleteOperation, metaGetOperation, metaGetOperation, patch, processMatchUrl, read, read, readEntity, readEntity, reindex, removeTag, removeTag, search, search, search, searchForIds, searchForIds, searchForIdsWithAndOr, translateRawParameters, update, update, update, update, update, validategetContext, getSearchParamByName, getSearchParamsByResourceType, injectDependenciesIntoBundleProvider, populateFullTextFields, processMatchUrl, toResource, toResourcepublic Long getSubscriptionTablePidForSubscriptionResource(IIdType theId)
getSubscriptionTablePidForSubscriptionResource in interface IFhirResourceDaoSubscription<Subscription>public List<IBaseResource> getUndeliveredResourcesAndPurge(Long theSubscriptionPid)
getUndeliveredResourcesAndPurge in interface IFhirResourceDaoSubscription<Subscription>@Transactional(propagation=NOT_SUPPORTED) public int pollForNewUndeliveredResources()
pollForNewUndeliveredResources in interface IFhirResourceDaoSubscription<Subscription>@Scheduled(fixedDelay=10000L) @Transactional(propagation=NOT_SUPPORTED) public void pollForNewUndeliveredResourcesScheduler()
pollForNewUndeliveredResourcesScheduler in interface IFhirResourceDaoSubscription<Subscription>protected void postPersist(ResourceTable theEntity, Subscription theSubscription)
BaseHapiFhirDaopostPersist in class BaseHapiFhirDao<Subscription>theEntity - The entity being updated (Do not modify the entity! Undefined behaviour will occur!)@Scheduled(fixedDelay=60000L) @Transactional(propagation=NOT_SUPPORTED) public void purgeInactiveSubscriptions()
purgeInactiveSubscriptions in interface IFhirResourceDaoSubscription<Subscription>protected ResourceTable updateEntity(IBaseResource theResource, ResourceTable theEntity, Date theDeletedTimestampOrNull, boolean thePerformIndexing, boolean theUpdateVersion, Date theUpdateTime)
updateEntity in class BaseHapiFhirDao<Subscription>protected void validateResourceForStorage(Subscription theResource, ResourceTable theEntityToSave)
BaseHapiFhirDaovalidateResourceForStorage in class BaseHapiFhirDao<Subscription>theResource - The resource that is about to be persistedtheEntityToSave - TODOCopyright © 2014–2017 University Health Network. All rights reserved.