Package ca.uhn.fhir.jpa.subscription

Class ResourceModifiedMessagePersistenceSvcImpl

java.lang.Object

ca.uhn.fhir.jpa.subscription.ResourceModifiedMessagePersistenceSvcImpl

All Implemented Interfaces:

IResourceModifiedMessagePersistenceSvc

public class ResourceModifiedMessagePersistenceSvcImpl
extends Object
implements IResourceModifiedMessagePersistenceSvc

This implementer provides the capability to persist subscription messages for asynchronous submission to the subscription processing pipeline with the purpose of offering a retry mechanism upon submission failure (see @link AsyncResourceModifiedSubmitterSvc).

Constructor Summary

Constructors

Constructor	Description
ResourceModifiedMessagePersistenceSvcImpl(ca.uhn.fhir.context.FhirContext theFhirContext, IResourceModifiedDao theResourceModifiedDao, DaoRegistry theDaoRegistry, HapiTransactionService theHapiTransactionService)

Method Summary

Modifier and Type	Method	Description
ResourceModifiedMessage	createResourceModifiedMessageFromEntityWithoutInflation(IPersistedResourceModifiedMessage thePersistedResourceModifiedMessage)
boolean	deleteByPK(IPersistedResourceModifiedMessagePK theResourceModifiedPK)
List<IPersistedResourceModifiedMessage>	findAllOrderedByCreatedTime()
long	getMessagePersistedCount()
ResourceModifiedMessage	inflatePersistedResourceModifiedMessage(ResourceModifiedMessage theResourceModifiedMessage)
Optional<ResourceModifiedMessage>	inflatePersistedResourceModifiedMessageOrNull(ResourceModifiedMessage theResourceModifiedMessage)
protected ResourceModifiedMessage	inflateResourceModifiedMessageFromEntity(ResourceModifiedEntity theResourceModifiedEntity)
IPersistedResourceModifiedMessage	persist(ResourceModifiedMessage theMsg)

Methods inherited from class java.lang.Object

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

Constructor Details

ResourceModifiedMessagePersistenceSvcImpl

public ResourceModifiedMessagePersistenceSvcImpl(ca.uhn.fhir.context.FhirContext theFhirContext,
 IResourceModifiedDao theResourceModifiedDao,
 DaoRegistry theDaoRegistry,
 HapiTransactionService theHapiTransactionService)

Method Details

findAllOrderedByCreatedTime

public List<IPersistedResourceModifiedMessage> findAllOrderedByCreatedTime()

Specified by:

findAllOrderedByCreatedTime in interface IResourceModifiedMessagePersistenceSvc

persist

public IPersistedResourceModifiedMessage persist(ResourceModifiedMessage theMsg)

Specified by:

persist in interface IResourceModifiedMessagePersistenceSvc

inflatePersistedResourceModifiedMessage

public ResourceModifiedMessage inflatePersistedResourceModifiedMessage(ResourceModifiedMessage theResourceModifiedMessage)

Specified by:

inflatePersistedResourceModifiedMessage in interface IResourceModifiedMessagePersistenceSvc

inflatePersistedResourceModifiedMessageOrNull

public Optional<ResourceModifiedMessage> inflatePersistedResourceModifiedMessageOrNull(ResourceModifiedMessage theResourceModifiedMessage)

Specified by:

inflatePersistedResourceModifiedMessageOrNull in interface IResourceModifiedMessagePersistenceSvc

createResourceModifiedMessageFromEntityWithoutInflation

public ResourceModifiedMessage createResourceModifiedMessageFromEntityWithoutInflation(IPersistedResourceModifiedMessage thePersistedResourceModifiedMessage)

Specified by:

createResourceModifiedMessageFromEntityWithoutInflation in interface IResourceModifiedMessagePersistenceSvc

getMessagePersistedCount

public long getMessagePersistedCount()

Specified by:

getMessagePersistedCount in interface IResourceModifiedMessagePersistenceSvc

deleteByPK

public boolean deleteByPK(IPersistedResourceModifiedMessagePK theResourceModifiedPK)

Specified by:

deleteByPK in interface IResourceModifiedMessagePersistenceSvc

inflateResourceModifiedMessageFromEntity

protected ResourceModifiedMessage inflateResourceModifiedMessageFromEntity(ResourceModifiedEntity theResourceModifiedEntity)