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

Class BaseSubscriptionDeliverySubscriber

java.lang.Object

ca.uhn.fhir.jpa.subscription.match.deliver.BaseSubscriptionDeliverySubscriber

All Implemented Interfaces:

org.springframework.messaging.MessageHandler

Direct Known Subclasses:

SubscriptionDeliveringEmailSubscriber, SubscriptionDeliveringMessageSubscriber, SubscriptionDeliveringRestHookSubscriber

public abstract class BaseSubscriptionDeliverySubscriber
extends Object
implements org.springframework.messaging.MessageHandler

Field Summary

Fields

Modifier and Type	Field	Description
protected ca.uhn.fhir.context.FhirContext	myFhirContext
protected IResourceModifiedMessagePersistenceSvc	myResourceModifiedMessagePersistenceSvc
protected SubscriptionRegistry	mySubscriptionRegistry

Constructor Summary

Constructors

Constructor	Description
BaseSubscriptionDeliverySubscriber()

Method Summary

Modifier and Type	Method	Description
protected org.hl7.fhir.instance.model.api.IBaseBundle	createDeliveryBundleForPayloadSearchCriteria(CanonicalSubscription theSubscription, org.hl7.fhir.instance.model.api.IBaseResource thePayloadResource)
ca.uhn.fhir.interceptor.api.IInterceptorBroadcaster	getInterceptorBroadcaster()
abstract void	handleMessage(ResourceDeliveryMessage theMessage)
void	handleMessage(org.springframework.messaging.Message theMessage)
protected Optional<ResourceModifiedMessage>	inflateResourceModifiedMessageFromDeliveryMessage(ResourceDeliveryMessage theMsg)
void	setDaoRegistryForUnitTest(DaoRegistry theDaoRegistry)
void	setFhirContextForUnitTest(ca.uhn.fhir.context.FhirContext theCtx)
void	setInterceptorBroadcasterForUnitTest(ca.uhn.fhir.interceptor.api.IInterceptorBroadcaster theInterceptorBroadcaster)
void	setMatchUrlServiceForUnitTest(MatchUrlService theMatchUrlService)
void	setResourceModifiedMessagePersistenceSvcForUnitTest(IResourceModifiedMessagePersistenceSvc theResourceModifiedMessagePersistenceSvc)
void	setSubscriptionRegistryForUnitTest(SubscriptionRegistry theSubscriptionRegistry)

Methods inherited from class java.lang.Object

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

Field Details

myFhirContext

@Autowired
protected ca.uhn.fhir.context.FhirContext myFhirContext

mySubscriptionRegistry

@Autowired
protected SubscriptionRegistry mySubscriptionRegistry

myResourceModifiedMessagePersistenceSvc

@Autowired
protected IResourceModifiedMessagePersistenceSvc myResourceModifiedMessagePersistenceSvc

Constructor Details

BaseSubscriptionDeliverySubscriber

public BaseSubscriptionDeliverySubscriber()

Method Details

handleMessage

public void handleMessage(org.springframework.messaging.Message theMessage)
                   throws org.springframework.messaging.MessagingException

Specified by:

handleMessage in interface org.springframework.messaging.MessageHandler

Throws:

org.springframework.messaging.MessagingException

handleMessage

public abstract void handleMessage(ResourceDeliveryMessage theMessage)
                            throws Exception

Throws:

Exception

createDeliveryBundleForPayloadSearchCriteria

protected org.hl7.fhir.instance.model.api.IBaseBundle createDeliveryBundleForPayloadSearchCriteria(CanonicalSubscription theSubscription,
 org.hl7.fhir.instance.model.api.IBaseResource thePayloadResource)

inflateResourceModifiedMessageFromDeliveryMessage

protected Optional<ResourceModifiedMessage> inflateResourceModifiedMessageFromDeliveryMessage(ResourceDeliveryMessage theMsg)

setFhirContextForUnitTest

public void setFhirContextForUnitTest(ca.uhn.fhir.context.FhirContext theCtx)

setInterceptorBroadcasterForUnitTest

public void setInterceptorBroadcasterForUnitTest(ca.uhn.fhir.interceptor.api.IInterceptorBroadcaster theInterceptorBroadcaster)

setSubscriptionRegistryForUnitTest

public void setSubscriptionRegistryForUnitTest(SubscriptionRegistry theSubscriptionRegistry)

setDaoRegistryForUnitTest

public void setDaoRegistryForUnitTest(DaoRegistry theDaoRegistry)

setMatchUrlServiceForUnitTest

public void setMatchUrlServiceForUnitTest(MatchUrlService theMatchUrlService)

setResourceModifiedMessagePersistenceSvcForUnitTest

public void setResourceModifiedMessagePersistenceSvcForUnitTest(IResourceModifiedMessagePersistenceSvc theResourceModifiedMessagePersistenceSvc)

getInterceptorBroadcaster

public ca.uhn.fhir.interceptor.api.IInterceptorBroadcaster getInterceptorBroadcaster()