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

Class SubscriptionDeliveringRestHookSubscriber

java.lang.Object

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

ca.uhn.fhir.jpa.subscription.match.deliver.resthook.SubscriptionDeliveringRestHookSubscriber

All Implemented Interfaces:

org.springframework.messaging.MessageHandler

@Scope("prototype")
public class SubscriptionDeliveringRestHookSubscriber
extends BaseSubscriptionDeliverySubscriber

Field Summary

Fields inherited from class ca.uhn.fhir.jpa.subscription.match.deliver.BaseSubscriptionDeliverySubscriber

myFhirContext, mySubscriptionRegistry

Constructor Summary

Constructors

Constructor	Description
SubscriptionDeliveringRestHookSubscriber()	Constructor

Method Summary

Modifier and Type	Method	Description
protected void	deliverPayload(ResourceDeliveryMessage theMsg, CanonicalSubscription theSubscription, ca.uhn.fhir.rest.api.EncodingEnum thePayloadType, ca.uhn.fhir.rest.client.api.IGenericClient theClient)
protected void	doDelivery(ResourceDeliveryMessage theMsg, CanonicalSubscription theSubscription, ca.uhn.fhir.rest.api.EncodingEnum thePayloadType, ca.uhn.fhir.rest.client.api.IGenericClient theClient, org.hl7.fhir.instance.model.api.IBaseResource thePayloadResource)
protected org.hl7.fhir.instance.model.api.IBaseResource	getAndMassagePayload(ResourceDeliveryMessage theMsg, CanonicalSubscription theSubscription)
org.hl7.fhir.instance.model.api.IBaseResource	getResource(org.hl7.fhir.instance.model.api.IIdType payloadId, RequestPartitionId thePartitionId, boolean theDeletedOK)
void	handleMessage(ResourceDeliveryMessage theMessage)
static List<ca.uhn.fhir.rest.client.api.Header>	parseHeadersFromSubscription(CanonicalSubscription subscription)
protected void	sendNotification(ResourceDeliveryMessage theMsg)	Sends a POST notification without a payload

Methods inherited from class ca.uhn.fhir.jpa.subscription.match.deliver.BaseSubscriptionDeliverySubscriber

createDeliveryBundleForPayloadSearchCriteria, getInterceptorBroadcaster, handleMessage, setDaoRegistryForUnitTest, setFhirContextForUnitTest, setInterceptorBroadcasterForUnitTest, setMatchUrlServiceForUnitTest, setSubscriptionRegistryForUnitTest

Methods inherited from class java.lang.Object

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

Constructor Details

SubscriptionDeliveringRestHookSubscriber

public SubscriptionDeliveringRestHookSubscriber()

Constructor

Method Details

deliverPayload

protected void deliverPayload(ResourceDeliveryMessage theMsg,
 CanonicalSubscription theSubscription,
 ca.uhn.fhir.rest.api.EncodingEnum thePayloadType,
 ca.uhn.fhir.rest.client.api.IGenericClient theClient)

doDelivery

protected void doDelivery(ResourceDeliveryMessage theMsg,
 CanonicalSubscription theSubscription,
 ca.uhn.fhir.rest.api.EncodingEnum thePayloadType,
 ca.uhn.fhir.rest.client.api.IGenericClient theClient,
 org.hl7.fhir.instance.model.api.IBaseResource thePayloadResource)

getResource

public org.hl7.fhir.instance.model.api.IBaseResource getResource(org.hl7.fhir.instance.model.api.IIdType payloadId,
 RequestPartitionId thePartitionId,
 boolean theDeletedOK)
                                                          throws ca.uhn.fhir.rest.server.exceptions.ResourceGoneException

Throws:

ca.uhn.fhir.rest.server.exceptions.ResourceGoneException

getAndMassagePayload

protected org.hl7.fhir.instance.model.api.IBaseResource getAndMassagePayload(ResourceDeliveryMessage theMsg,
 CanonicalSubscription theSubscription)

handleMessage

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

Specified by:

handleMessage in class BaseSubscriptionDeliverySubscriber

Throws:

org.springframework.messaging.MessagingException

sendNotification

protected void sendNotification(ResourceDeliveryMessage theMsg)

Sends a POST notification without a payload

parseHeadersFromSubscription

public static List<ca.uhn.fhir.rest.client.api.Header> parseHeadersFromSubscription(CanonicalSubscription subscription)