Index

A B C D E G H I J L M N P R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values

A

activateSubscriptionIfRequired(IBaseResource) - Method in class ca.uhn.fhir.jpa.subscription.match.matcher.subscriber.SubscriptionActivatingSubscriber

Note: This is synchronized because this is called both by matching channel messages as well as from Subscription Loader (which periodically refreshes from the DB to make sure nothing got missed).

ActiveSubscription - Class in ca.uhn.fhir.jpa.subscription.match.registry

ActiveSubscription(CanonicalSubscription, String) - Constructor for class ca.uhn.fhir.jpa.subscription.match.registry.ActiveSubscription

ActiveSubscriptionTopicCache - Class in ca.uhn.fhir.jpa.topic

ActiveSubscriptionTopicCache() - Constructor for class ca.uhn.fhir.jpa.topic.ActiveSubscriptionTopicCache

add(ActiveSubscription) - Method in class ca.uhn.fhir.jpa.subscription.channel.subscription.SubscriptionChannelRegistry

add(SubscriptionTopic) - Method in class ca.uhn.fhir.jpa.topic.ActiveSubscriptionTopicCache

addHandler(MessageHandler) - Method in class ca.uhn.fhir.jpa.subscription.channel.subscription.SubscriptionChannelWithHandlers

afterConnectionClosed(WebSocketSession, CloseStatus) - Method in class ca.uhn.fhir.jpa.subscription.match.deliver.websocket.SubscriptionWebsocketHandler

afterConnectionEstablished(WebSocketSession) - Method in class ca.uhn.fhir.jpa.subscription.match.deliver.websocket.SubscriptionWebsocketHandler

asyncResourceModifiedProcessingSchedulerSvc() - Method in class ca.uhn.fhir.jpa.subscription.submit.config.SubscriptionSubmitterConfig

AsyncResourceModifiedProcessingSchedulerSvc - Class in ca.uhn.fhir.jpa.subscription.async

This service is responsible for scheduling a job that will submit messages to the subscription processing pipeline at a given interval.

AsyncResourceModifiedProcessingSchedulerSvc() - Constructor for class ca.uhn.fhir.jpa.subscription.async.AsyncResourceModifiedProcessingSchedulerSvc

AsyncResourceModifiedProcessingSchedulerSvc(long) - Constructor for class ca.uhn.fhir.jpa.subscription.async.AsyncResourceModifiedProcessingSchedulerSvc

AsyncResourceModifiedProcessingSchedulerSvc.Job - Class in ca.uhn.fhir.jpa.subscription.async

asyncResourceModifiedSubmitterSvc(IResourceModifiedMessagePersistenceSvc, IResourceModifiedConsumerWithRetries) - Method in class ca.uhn.fhir.jpa.subscription.submit.config.SubscriptionSubmitterConfig

AsyncResourceModifiedSubmitterSvc - Class in ca.uhn.fhir.jpa.subscription.async

The purpose of this service is to submit messages to the processing pipeline for which previous attempts at submission has failed.

AsyncResourceModifiedSubmitterSvc(IResourceModifiedMessagePersistenceSvc, IResourceModifiedConsumerWithRetries) - Constructor for class ca.uhn.fhir.jpa.subscription.async.AsyncResourceModifiedSubmitterSvc

B

BaseChannelParameters - Class in ca.uhn.fhir.jpa.subscription.channel.models

BaseChannelParameters(String) - Constructor for class ca.uhn.fhir.jpa.subscription.channel.models.BaseChannelParameters

Constructor

BaseSubscriptionDeliverySubscriber - Class in ca.uhn.fhir.jpa.subscription.match.deliver

BaseSubscriptionDeliverySubscriber() - Constructor for class ca.uhn.fhir.jpa.subscription.match.deliver.BaseSubscriptionDeliverySubscriber

buildNotificationStatus(List<IBaseResource>, ActiveSubscription, String) - Method in interface ca.uhn.fhir.jpa.topic.status.INotificationStatusBuilder

Build a notification status resource to include as the first element in a topic subscription notification bundle

buildNotificationStatus(List<IBaseResource>, ActiveSubscription, String) - Method in class ca.uhn.fhir.jpa.topic.status.R4BNotificationStatusBuilder

buildNotificationStatus(List<IBaseResource>, ActiveSubscription, String) - Method in class ca.uhn.fhir.jpa.topic.status.R4NotificationStatusBuilder

buildNotificationStatus(List<IBaseResource>, ActiveSubscription, String) - Method in class ca.uhn.fhir.jpa.topic.status.R5NotificationStatusBuilder

buildPayload(List<IBaseResource>, ActiveSubscription, String, RestOperationTypeEnum) - Method in class ca.uhn.fhir.jpa.topic.SubscriptionTopicPayloadBuilder

C

ca.uhn.fhir.jpa.subscription - package ca.uhn.fhir.jpa.subscription

Module to support Subscriptions

ca.uhn.fhir.jpa.subscription.api - package ca.uhn.fhir.jpa.subscription.api

ca.uhn.fhir.jpa.subscription.async - package ca.uhn.fhir.jpa.subscription.async

ca.uhn.fhir.jpa.subscription.channel.models - package ca.uhn.fhir.jpa.subscription.channel.models

ca.uhn.fhir.jpa.subscription.channel.subscription - package ca.uhn.fhir.jpa.subscription.channel.subscription

ca.uhn.fhir.jpa.subscription.match.config - package ca.uhn.fhir.jpa.subscription.match.config

ca.uhn.fhir.jpa.subscription.match.deliver - package ca.uhn.fhir.jpa.subscription.match.deliver

ca.uhn.fhir.jpa.subscription.match.deliver.email - package ca.uhn.fhir.jpa.subscription.match.deliver.email

ca.uhn.fhir.jpa.subscription.match.deliver.message - package ca.uhn.fhir.jpa.subscription.match.deliver.message

ca.uhn.fhir.jpa.subscription.match.deliver.resthook - package ca.uhn.fhir.jpa.subscription.match.deliver.resthook

ca.uhn.fhir.jpa.subscription.match.deliver.websocket - package ca.uhn.fhir.jpa.subscription.match.deliver.websocket

ca.uhn.fhir.jpa.subscription.match.matcher.matching - package ca.uhn.fhir.jpa.subscription.match.matcher.matching

ca.uhn.fhir.jpa.subscription.match.matcher.subscriber - package ca.uhn.fhir.jpa.subscription.match.matcher.subscriber

ca.uhn.fhir.jpa.subscription.match.registry - package ca.uhn.fhir.jpa.subscription.match.registry

ca.uhn.fhir.jpa.subscription.model.config - package ca.uhn.fhir.jpa.subscription.model.config

ca.uhn.fhir.jpa.subscription.submit.config - package ca.uhn.fhir.jpa.subscription.submit.config

ca.uhn.fhir.jpa.subscription.submit.interceptor - package ca.uhn.fhir.jpa.subscription.submit.interceptor

ca.uhn.fhir.jpa.subscription.submit.svc - package ca.uhn.fhir.jpa.subscription.submit.svc

ca.uhn.fhir.jpa.subscription.triggering - package ca.uhn.fhir.jpa.subscription.triggering

ca.uhn.fhir.jpa.subscription.util - package ca.uhn.fhir.jpa.subscription.util

ca.uhn.fhir.jpa.topic - package ca.uhn.fhir.jpa.topic

ca.uhn.fhir.jpa.topic.filter - package ca.uhn.fhir.jpa.topic.filter

ca.uhn.fhir.jpa.topic.status - package ca.uhn.fhir.jpa.topic.status

cancelAll() - Method in class ca.uhn.fhir.jpa.subscription.triggering.SubscriptionTriggeringSvcImpl

canonicalizeTopic(FhirContext, IBaseResource) - Static method in class ca.uhn.fhir.jpa.topic.SubscriptionTopicCanonicalizer

close() - Method in class ca.uhn.fhir.jpa.subscription.channel.subscription.SubscriptionChannelWithHandlers

CompositeInMemoryDaoSubscriptionMatcher - Class in ca.uhn.fhir.jpa.subscription.match.matcher.matching

CompositeInMemoryDaoSubscriptionMatcher(DaoSubscriptionMatcher, InMemorySubscriptionMatcher) - Constructor for class ca.uhn.fhir.jpa.subscription.match.matcher.matching.CompositeInMemoryDaoSubscriptionMatcher

createDeliveryBundleForPayloadSearchCriteria(CanonicalSubscription, IBaseResource) - Method in class ca.uhn.fhir.jpa.subscription.match.deliver.BaseSubscriptionDeliverySubscriber

createDeliveryHandler(CanonicalSubscriptionChannelType) - Method in class ca.uhn.fhir.jpa.subscription.channel.subscription.SubscriptionDeliveryHandlerFactory

createRequestDetailForPartitionedRequest(CanonicalSubscription) - Static method in class ca.uhn.fhir.jpa.subscription.util.SubscriptionUtil

createResourceModifiedMessage(IBaseResource, BaseResourceMessage.OperationTypeEnum, RequestDetails) - Method in class ca.uhn.fhir.jpa.subscription.submit.interceptor.SubscriptionMatcherInterceptor

D

daoSubscriptionMatcher() - Method in class ca.uhn.fhir.jpa.subscription.match.config.SubscriptionProcessorConfig

DaoSubscriptionMatcher - Class in ca.uhn.fhir.jpa.subscription.match.matcher.matching

DaoSubscriptionMatcher() - Constructor for class ca.uhn.fhir.jpa.subscription.match.matcher.matching.DaoSubscriptionMatcher

DEFAULT_SUBMISSION_INTERVAL_IN_MS - Static variable in class ca.uhn.fhir.jpa.subscription.async.AsyncResourceModifiedProcessingSchedulerSvc

deliverPayload(SubscriptionDeliveryRequest, InMemoryMatchResult) - Method in class ca.uhn.fhir.jpa.subscription.match.matcher.subscriber.SubscriptionMatchDeliverer

deliverPayload(ResourceDeliveryMessage, CanonicalSubscription, EncodingEnum, IGenericClient) - Method in class ca.uhn.fhir.jpa.subscription.match.deliver.resthook.SubscriptionDeliveringRestHookSubscriber

deliverPayload(IBaseResource, ResourceModifiedMessage, ActiveSubscription, InMemoryMatchResult) - Method in class ca.uhn.fhir.jpa.subscription.match.matcher.subscriber.SubscriptionMatchDeliverer

determineStrategy(CanonicalSubscription) - Method in class ca.uhn.fhir.jpa.subscription.match.matcher.matching.SubscriptionStrategyEvaluator

determineStrategy(String) - Method in class ca.uhn.fhir.jpa.subscription.match.matcher.matching.SubscriptionStrategyEvaluator

determineStrategy(String) - Method in class ca.uhn.fhir.jpa.subscription.submit.interceptor.SubscriptionQueryValidator

dispatch(SubscriptionTopicDispatchRequest) - Method in class ca.uhn.fhir.jpa.topic.SubscriptionTopicDispatcher

Deliver a Subscription topic notification to all subscriptions for the given topic.

dispatch(String, List<IBaseResource>, RestOperationTypeEnum) - Method in class ca.uhn.fhir.jpa.topic.SubscriptionTopicDispatcher

Deliver a Subscription topic notification to all subscriptions for the given topic.

doDelivery(ResourceDeliveryMessage, CanonicalSubscription, IChannelProducer, ResourceModifiedJsonMessage) - Method in class ca.uhn.fhir.jpa.subscription.match.deliver.message.SubscriptionDeliveringMessageSubscriber

doDelivery(ResourceDeliveryMessage, CanonicalSubscription, EncodingEnum, IGenericClient, IBaseResource) - Method in class ca.uhn.fhir.jpa.subscription.match.deliver.resthook.SubscriptionDeliveringRestHookSubscriber

doProcessResourceModifiedInTransaction(IPersistedResourceModifiedMessage) - Method in class ca.uhn.fhir.jpa.subscription.submit.svc.ResourceModifiedSubmitterSvc

This method is the cornerstone in the submit and retry upon failure mechanism for messages needing submission to the subscription processing pipeline.

doSyncSubscriptionsForUnitTest() - Method in class ca.uhn.fhir.jpa.subscription.match.registry.SubscriptionLoader

E

EmailDetails - Class in ca.uhn.fhir.jpa.subscription.match.deliver.email

EmailDetails() - Constructor for class ca.uhn.fhir.jpa.subscription.match.deliver.email.EmailDetails

EmailSenderImpl - Class in ca.uhn.fhir.jpa.subscription.match.deliver.email

EmailSenderImpl(IMailSvc) - Constructor for class ca.uhn.fhir.jpa.subscription.match.deliver.email.EmailSenderImpl

execute(JobExecutionContext) - Method in class ca.uhn.fhir.jpa.subscription.async.AsyncResourceModifiedProcessingSchedulerSvc.Job

execute(JobExecutionContext) - Method in class ca.uhn.fhir.jpa.subscription.triggering.SubscriptionTriggeringSvcImpl.Job

G

get(String) - Method in class ca.uhn.fhir.jpa.subscription.match.registry.SubscriptionRegistry

getActiveJobCount() - Method in class ca.uhn.fhir.jpa.subscription.triggering.SubscriptionTriggeringSvcImpl

getActiveSubscription() - Method in class ca.uhn.fhir.jpa.subscription.match.deliver.websocket.WebsocketValidationResponse

getActiveSubscription() - Method in class ca.uhn.fhir.jpa.subscription.match.matcher.subscriber.SubscriptionDeliveryRequest

getAll() - Method in class ca.uhn.fhir.jpa.subscription.match.registry.SubscriptionRegistry

getAll() - Method in class ca.uhn.fhir.jpa.topic.ActiveSubscriptionTopicCache

getAll() - Method in class ca.uhn.fhir.jpa.topic.SubscriptionTopicRegistry

getAllNonTopicSubscriptions() - Method in class ca.uhn.fhir.jpa.subscription.match.registry.SubscriptionRegistry

getAndMassagePayload(ResourceDeliveryMessage, CanonicalSubscription) - Method in class ca.uhn.fhir.jpa.subscription.match.deliver.resthook.SubscriptionDeliveringRestHookSubscriber

Perform operations on the payload based on various subscription extension settings such as deliver latest version, delete and/or strip version id.

getApplicableResourceTypes() - Method in class ca.uhn.fhir.jpa.subscription.match.matcher.subscriber.SubscriptionCriteriaParser.SubscriptionCriteria

getBody() - Method in class ca.uhn.fhir.jpa.subscription.match.deliver.email.EmailDetails

getChannel() - Method in class ca.uhn.fhir.jpa.subscription.channel.subscription.SubscriptionChannelWithHandlers

getChannelName() - Method in class ca.uhn.fhir.jpa.subscription.channel.models.BaseChannelParameters

getChannelName() - Method in class ca.uhn.fhir.jpa.subscription.match.registry.ActiveSubscription

getChannelType() - Method in class ca.uhn.fhir.jpa.subscription.match.registry.ActiveSubscription

getCriteria() - Method in class ca.uhn.fhir.jpa.subscription.match.matcher.subscriber.SubscriptionCriteriaParser.SubscriptionCriteria

getCriteria() - Method in class ca.uhn.fhir.jpa.subscription.match.registry.ActiveSubscription

getDaoRegistry() - Method in class ca.uhn.fhir.jpa.topic.SubscriptionTopicSupport

getDeliveriesCount() - Method in class ca.uhn.fhir.jpa.subscription.match.registry.ActiveSubscription

getDeliveryHandlerForUnitTest() - Method in class ca.uhn.fhir.jpa.subscription.channel.subscription.SubscriptionChannelWithHandlers

getDeliveryReceiverChannel(String) - Method in class ca.uhn.fhir.jpa.subscription.channel.subscription.SubscriptionChannelRegistry

getDeliverySenderChannel(String) - Method in class ca.uhn.fhir.jpa.subscription.channel.subscription.SubscriptionChannelRegistry

getEmailSender() - Method in class ca.uhn.fhir.jpa.subscription.match.deliver.email.SubscriptionDeliveringEmailSubscriber

getFhirContext() - Method in class ca.uhn.fhir.jpa.topic.SubscriptionTopicSupport

getFrom() - Method in class ca.uhn.fhir.jpa.subscription.match.deliver.email.EmailDetails

getId() - Method in class ca.uhn.fhir.jpa.subscription.match.registry.ActiveSubscription

getInMemoryMatchResult() - Method in class ca.uhn.fhir.jpa.topic.SubscriptionTopicDispatchRequest

getInterceptorBroadcaster() - Method in class ca.uhn.fhir.jpa.subscription.match.deliver.BaseSubscriptionDeliverySubscriber

getMessage() - Method in class ca.uhn.fhir.jpa.subscription.match.deliver.websocket.WebsocketValidationResponse

getMessageKeyOrNull(IBaseResource) - Method in interface ca.uhn.fhir.jpa.subscription.api.ISubscriptionMessageKeySvc

Given an IBaseResource, return a key that can be used to identify the message.

getOperationType() - Method in class ca.uhn.fhir.jpa.subscription.match.matcher.subscriber.SubscriptionDeliveryRequest

getPayload() - Method in class ca.uhn.fhir.jpa.subscription.match.matcher.subscriber.SubscriptionDeliveryRequest

getPayloadId() - Method in class ca.uhn.fhir.jpa.subscription.match.matcher.subscriber.SubscriptionDeliveryRequest

getProcessingChannelForUnitTest() - Method in class ca.uhn.fhir.jpa.subscription.submit.svc.ResourceModifiedSubmitterSvc

getRequestPartitionId() - Method in class ca.uhn.fhir.jpa.subscription.match.matcher.subscriber.SubscriptionDeliveryRequest

getRequestPartitionId() - Method in class ca.uhn.fhir.jpa.topic.SubscriptionTopicDispatchRequest

getRequestType() - Method in class ca.uhn.fhir.jpa.topic.SubscriptionTopicDispatchRequest

getResource(IIdType, RequestPartitionId, boolean) - Method in class ca.uhn.fhir.jpa.subscription.match.deliver.resthook.SubscriptionDeliveringRestHookSubscriber

getResources() - Method in class ca.uhn.fhir.jpa.topic.SubscriptionTopicDispatchRequest

getRestOperationType() - Method in class ca.uhn.fhir.jpa.subscription.match.matcher.subscriber.SubscriptionDeliveryRequest

getRetryConfiguration() - Method in class ca.uhn.fhir.jpa.subscription.channel.models.BaseChannelParameters

getRetryConfigurationParameters() - Method in class ca.uhn.fhir.jpa.subscription.match.registry.ActiveSubscription

getSearchParameterMap() - Method in class ca.uhn.fhir.jpa.subscription.match.registry.SubscriptionLoader

getSearchParameterMap() - Method in class ca.uhn.fhir.jpa.topic.SubscriptionTopicLoader

getSearchParamMatcher() - Method in class ca.uhn.fhir.jpa.topic.SubscriptionTopicSupport

getSubject() - Method in class ca.uhn.fhir.jpa.subscription.match.deliver.email.EmailDetails

getSubscription() - Method in class ca.uhn.fhir.jpa.subscription.match.matcher.subscriber.SubscriptionDeliveryRequest

getSubscription() - Method in class ca.uhn.fhir.jpa.subscription.match.registry.ActiveSubscription

getSubscriptionId() - Method in class ca.uhn.fhir.jpa.subscription.match.deliver.email.EmailDetails

getSubscriptionTopicFilterMatcher() - Method in class ca.uhn.fhir.jpa.topic.SubscriptionTopicDispatchRequest

getTo() - Method in class ca.uhn.fhir.jpa.subscription.match.deliver.email.EmailDetails

getTopicSubscriptionsByTopic(String) - Method in class ca.uhn.fhir.jpa.subscription.match.registry.SubscriptionRegistry

getTopicUrl() - Method in class ca.uhn.fhir.jpa.topic.SubscriptionTopicDispatchRequest

getTransactionId() - Method in class ca.uhn.fhir.jpa.subscription.match.matcher.subscriber.SubscriptionDeliveryRequest

getTransactionId() - Method in class ca.uhn.fhir.jpa.topic.SubscriptionTopicDispatchRequest

getType() - Method in class ca.uhn.fhir.jpa.subscription.match.matcher.subscriber.SubscriptionCriteriaParser.SubscriptionCriteria

H

handleFailure(Exception) - Method in class ca.uhn.fhir.jpa.subscription.match.deliver.websocket.SubscriptionWebsocketHandler

handleInit(List<IBaseResource>) - Method in class ca.uhn.fhir.jpa.subscription.match.registry.SubscriptionLoader

handleInit(List<IBaseResource>) - Method in class ca.uhn.fhir.jpa.topic.SubscriptionTopicLoader

handleMessage(ResourceDeliveryMessage) - Method in class ca.uhn.fhir.jpa.subscription.match.deliver.BaseSubscriptionDeliverySubscriber

handleMessage(ResourceDeliveryMessage) - Method in class ca.uhn.fhir.jpa.subscription.match.deliver.email.SubscriptionDeliveringEmailSubscriber

handleMessage(ResourceDeliveryMessage) - Method in class ca.uhn.fhir.jpa.subscription.match.deliver.message.SubscriptionDeliveringMessageSubscriber

handleMessage(ResourceDeliveryMessage) - Method in class ca.uhn.fhir.jpa.subscription.match.deliver.resthook.SubscriptionDeliveringRestHookSubscriber

handleMessage(Message) - Method in class ca.uhn.fhir.jpa.subscription.match.deliver.BaseSubscriptionDeliverySubscriber

handleMessage(Message<?>) - Method in class ca.uhn.fhir.jpa.subscription.match.matcher.subscriber.SubscriptionActivatingSubscriber

handleMessage(Message<?>) - Method in class ca.uhn.fhir.jpa.subscription.match.matcher.subscriber.SubscriptionMatchingSubscriber

handleMessage(Message<?>) - Method in class ca.uhn.fhir.jpa.subscription.match.matcher.subscriber.SubscriptionRegisteringSubscriber

handleMessage(Message<?>) - Method in class ca.uhn.fhir.jpa.topic.SubscriptionTopicMatchingSubscriber

handleMessage(Message<?>) - Method in class ca.uhn.fhir.jpa.topic.SubscriptionTopicRegisteringSubscriber

handleTextMessage(WebSocketSession, TextMessage) - Method in class ca.uhn.fhir.jpa.subscription.match.deliver.websocket.SubscriptionWebsocketHandler

handleTransportError(WebSocketSession, Throwable) - Method in class ca.uhn.fhir.jpa.subscription.match.deliver.websocket.SubscriptionWebsocketHandler

hasPayload() - Method in class ca.uhn.fhir.jpa.subscription.match.matcher.subscriber.SubscriptionDeliveryRequest

I

IEmailSender - Interface in ca.uhn.fhir.jpa.subscription.match.deliver.email

incrementDeliveriesCount() - Method in class ca.uhn.fhir.jpa.subscription.match.registry.ActiveSubscription

inMemorySubscriptionMatcher() - Method in class ca.uhn.fhir.jpa.subscription.match.config.SubscriptionProcessorConfig

InMemorySubscriptionMatcher - Class in ca.uhn.fhir.jpa.subscription.match.matcher.matching

InMemorySubscriptionMatcher() - Constructor for class ca.uhn.fhir.jpa.subscription.match.matcher.matching.InMemorySubscriptionMatcher

InMemoryTopicFilterMatcher - Class in ca.uhn.fhir.jpa.topic.filter

InMemoryTopicFilterMatcher(SearchParamMatcher) - Constructor for class ca.uhn.fhir.jpa.topic.filter.InMemoryTopicFilterMatcher

INotificationStatusBuilder<T extends org.hl7.fhir.instance.model.api.IBaseResource> - Interface in ca.uhn.fhir.jpa.topic.status

INVALID_RESPONSE(String) - Static method in class ca.uhn.fhir.jpa.subscription.match.deliver.websocket.WebsocketValidationResponse

isChannelTypeSupported(IBaseResource) - Method in class ca.uhn.fhir.jpa.subscription.match.matcher.subscriber.SubscriptionActivatingSubscriber

isFlagForDeletion() - Method in class ca.uhn.fhir.jpa.subscription.match.registry.ActiveSubscription

ISubscriptionDeliveryChannelNamer - Interface in ca.uhn.fhir.jpa.subscription.channel.subscription

ISubscriptionMatcher - Interface in ca.uhn.fhir.jpa.subscription.match.matcher.matching

ISubscriptionMessageKeySvc - Interface in ca.uhn.fhir.jpa.subscription.api

This is used by "message" type subscriptions to provide a key to the message wrapper before submitting it to the channel

ISubscriptionTopicFilterMatcher - Interface in ca.uhn.fhir.jpa.topic.filter

isValid() - Method in class ca.uhn.fhir.jpa.subscription.match.deliver.websocket.WebsocketValidationResponse

J

Job() - Constructor for class ca.uhn.fhir.jpa.subscription.async.AsyncResourceModifiedProcessingSchedulerSvc.Job

Job() - Constructor for class ca.uhn.fhir.jpa.subscription.triggering.SubscriptionTriggeringSvcImpl.Job

L

log(SubscriptionDebugLogInterceptor.EventCodeEnum, String, Object...) - Method in class ca.uhn.fhir.jpa.subscription.util.SubscriptionDebugLogInterceptor

logForUnitTest() - Method in class ca.uhn.fhir.jpa.subscription.channel.subscription.SubscriptionChannelRegistry

M

match() - Method in class ca.uhn.fhir.jpa.topic.SubscriptionTriggerMatcher

match(CanonicalSubscription, ResourceModifiedMessage) - Method in class ca.uhn.fhir.jpa.subscription.match.matcher.matching.CompositeInMemoryDaoSubscriptionMatcher

match(CanonicalSubscription, ResourceModifiedMessage) - Method in class ca.uhn.fhir.jpa.subscription.match.matcher.matching.DaoSubscriptionMatcher

match(CanonicalSubscription, ResourceModifiedMessage) - Method in class ca.uhn.fhir.jpa.subscription.match.matcher.matching.InMemorySubscriptionMatcher

match(CanonicalSubscription, ResourceModifiedMessage) - Method in interface ca.uhn.fhir.jpa.subscription.match.matcher.matching.ISubscriptionMatcher

match(CanonicalTopicSubscriptionFilter, IBaseResource) - Method in class ca.uhn.fhir.jpa.topic.filter.InMemoryTopicFilterMatcher

match(CanonicalTopicSubscriptionFilter, IBaseResource) - Method in interface ca.uhn.fhir.jpa.topic.filter.ISubscriptionTopicFilterMatcher

Match a resource against a single subscription topic filter

match(ResourceModifiedMessage) - Method in class ca.uhn.fhir.jpa.topic.SubscriptionTopicMatcher

matchActiveSubscriptionsAndDeliver(ResourceModifiedMessage) - Method in class ca.uhn.fhir.jpa.subscription.match.matcher.subscriber.SubscriptionMatchingSubscriber

matches(BaseResourceMessage.OperationTypeEnum, List<Enumeration<SubscriptionTopic.InteractionTrigger>>) - Static method in class ca.uhn.fhir.jpa.topic.SubscriptionTopicUtil

matchFilters(IBaseResource, String, ISubscriptionTopicFilterMatcher, CanonicalTopicSubscription) - Static method in class ca.uhn.fhir.jpa.topic.filter.SubscriptionTopicFilterUtil

MatchingQueueSubscriberLoader - Class in ca.uhn.fhir.jpa.subscription.match.matcher.subscriber

MatchingQueueSubscriberLoader() - Constructor for class ca.uhn.fhir.jpa.subscription.match.matcher.subscriber.MatchingQueueSubscriberLoader

MULTITYPE_EXPRESSION - Enum constant in enum ca.uhn.fhir.jpa.subscription.match.matcher.subscriber.SubscriptionCriteriaParser.TypeEnum

Collection of resource types

myApplicationContext - Variable in class ca.uhn.fhir.jpa.subscription.channel.subscription.SubscriptionDeliveryHandlerFactory

myFhirContext - Variable in class ca.uhn.fhir.jpa.subscription.match.deliver.BaseSubscriptionDeliverySubscriber

myMatchingChannel - Variable in class ca.uhn.fhir.jpa.subscription.match.matcher.subscriber.MatchingQueueSubscriberLoader

mySubmissionIntervalInMilliSeconds - Variable in class ca.uhn.fhir.jpa.subscription.async.AsyncResourceModifiedProcessingSchedulerSvc

mySubscriptionRegistry - Variable in class ca.uhn.fhir.jpa.subscription.match.deliver.BaseSubscriptionDeliverySubscriber

myWebsocketConnectionValidator - Variable in class ca.uhn.fhir.jpa.subscription.match.deliver.websocket.SubscriptionWebsocketHandler

N

nameFromSubscription(CanonicalSubscription) - Method in interface ca.uhn.fhir.jpa.subscription.channel.subscription.ISubscriptionDeliveryChannelNamer

nameFromSubscription(CanonicalSubscription) - Method in class ca.uhn.fhir.jpa.subscription.channel.subscription.SubscriptionDeliveryChannelNamer

newReceivingChannel(ReceivingChannelParameters) - Method in class ca.uhn.fhir.jpa.subscription.channel.subscription.SubscriptionChannelRegistry

newSendingChannel(ProducingChannelParameters) - Method in class ca.uhn.fhir.jpa.subscription.channel.subscription.SubscriptionChannelRegistry

newSubscriptionDeliveringEmailSubscriber(IEmailSender) - Method in class ca.uhn.fhir.jpa.subscription.channel.subscription.SubscriptionDeliveryHandlerFactory

newSubscriptionDeliveringMessageSubscriber() - Method in class ca.uhn.fhir.jpa.subscription.channel.subscription.SubscriptionDeliveryHandlerFactory

newSubscriptionDeliveringRestHookSubscriber() - Method in class ca.uhn.fhir.jpa.subscription.channel.subscription.SubscriptionDeliveryHandlerFactory

P

parse(String) - Static method in enum ca.uhn.fhir.jpa.subscription.match.matcher.subscriber.SubscriptionCriteriaParser

parseHeadersFromSubscription(CanonicalSubscription) - Static method in class ca.uhn.fhir.jpa.subscription.match.deliver.resthook.SubscriptionDeliveringRestHookSubscriber

postConstruct() - Method in class ca.uhn.fhir.jpa.subscription.match.deliver.websocket.SubscriptionWebsocketHandler

preDescroy() - Method in class ca.uhn.fhir.jpa.subscription.match.deliver.websocket.SubscriptionWebsocketHandler

processResourceModifiedEvent(IBaseResource, BaseResourceMessage.OperationTypeEnum, RequestDetails) - Method in class ca.uhn.fhir.jpa.subscription.submit.interceptor.SubscriptionMatcherInterceptor

This is an internal API - Use with caution! This method will create a ResourceModifiedMessage, persist it and arrange for its delivery to the subscription pipeline after the resource was committed.

processResourceModifiedMessage(ResourceModifiedMessage) - Method in class ca.uhn.fhir.jpa.subscription.submit.interceptor.SubscriptionMatcherInterceptor

processResourceModifiedMessage(ResourceModifiedMessage) - Method in class ca.uhn.fhir.jpa.subscription.submit.interceptor.SynchronousSubscriptionMatcherInterceptor

ProducingChannelParameters - Class in ca.uhn.fhir.jpa.subscription.channel.models

ProducingChannelParameters(String) - Constructor for class ca.uhn.fhir.jpa.subscription.channel.models.ProducingChannelParameters

Constructor

R

R4BNotificationStatusBuilder - Class in ca.uhn.fhir.jpa.topic.status

R4BNotificationStatusBuilder(FhirContext) - Constructor for class ca.uhn.fhir.jpa.topic.status.R4BNotificationStatusBuilder

R4NotificationStatusBuilder - Class in ca.uhn.fhir.jpa.topic.status

R4NotificationStatusBuilder(FhirContext) - Constructor for class ca.uhn.fhir.jpa.topic.status.R4NotificationStatusBuilder

R5NotificationStatusBuilder - Class in ca.uhn.fhir.jpa.topic.status

R5NotificationStatusBuilder(FhirContext) - Constructor for class ca.uhn.fhir.jpa.topic.status.R5NotificationStatusBuilder

ReceivingChannelParameters - Class in ca.uhn.fhir.jpa.subscription.channel.models

ReceivingChannelParameters(String) - Constructor for class ca.uhn.fhir.jpa.subscription.channel.models.ReceivingChannelParameters

Constructor

register(SubscriptionTopic) - Method in class ca.uhn.fhir.jpa.topic.SubscriptionTopicRegistry

registerListener() - Method in class ca.uhn.fhir.jpa.topic.SubscriptionTopicLoader

registerSubscriptionUnlessAlreadyRegistered(IBaseResource) - Method in class ca.uhn.fhir.jpa.subscription.match.registry.SubscriptionRegistry

registerWebSocketHandlers(WebSocketHandlerRegistry) - Method in class ca.uhn.fhir.jpa.subscription.match.config.WebsocketDispatcherConfig

remove(ActiveSubscription) - Method in class ca.uhn.fhir.jpa.subscription.channel.subscription.SubscriptionChannelRegistry

remove(String) - Method in class ca.uhn.fhir.jpa.topic.ActiveSubscriptionTopicCache

removeHandler(MessageHandler) - Method in class ca.uhn.fhir.jpa.subscription.channel.subscription.SubscriptionChannelWithHandlers

removeIdsNotInCollection(Set<String>) - Method in class ca.uhn.fhir.jpa.topic.ActiveSubscriptionTopicCache

resourceCreated(IBaseResource, RequestDetails) - Method in class ca.uhn.fhir.jpa.subscription.submit.interceptor.SubscriptionMatcherInterceptor

resourceDeleted(IBaseResource, RequestDetails) - Method in class ca.uhn.fhir.jpa.subscription.submit.interceptor.SubscriptionMatcherInterceptor

ResourceModifiedSubmitterSvc - Class in ca.uhn.fhir.jpa.subscription.submit.svc

This service provides two distinct contexts in which it submits messages to the subscription pipeline.

ResourceModifiedSubmitterSvc(StorageSettings, SubscriptionChannelFactory, IResourceModifiedMessagePersistenceSvc, IHapiTransactionService) - Constructor for class ca.uhn.fhir.jpa.subscription.submit.svc.ResourceModifiedSubmitterSvc

resourceModifiedSvc(IHapiTransactionService, IResourceModifiedMessagePersistenceSvc, SubscriptionChannelFactory, StorageSettings) - Method in class ca.uhn.fhir.jpa.subscription.submit.config.SubscriptionSubmitterConfig

resourcePreCreate(IBaseResource, RequestDetails, RequestPartitionId) - Method in class ca.uhn.fhir.jpa.subscription.submit.interceptor.SubscriptionValidatingInterceptor

resourcePreCreate(IBaseResource, RequestDetails, RequestPartitionId) - Method in class ca.uhn.fhir.jpa.topic.SubscriptionTopicValidatingInterceptor

resourceUpdated(IBaseResource, IBaseResource, RequestDetails) - Method in class ca.uhn.fhir.jpa.subscription.submit.interceptor.SubscriptionMatcherInterceptor

resourceUpdated(IBaseResource, IBaseResource, RequestDetails, RequestPartitionId) - Method in class ca.uhn.fhir.jpa.subscription.submit.interceptor.SubscriptionValidatingInterceptor

resourceUpdated(IBaseResource, IBaseResource, RequestDetails, RequestPartitionId) - Method in class ca.uhn.fhir.jpa.topic.SubscriptionTopicValidatingInterceptor

runDeliveryPass() - Method in class ca.uhn.fhir.jpa.subscription.async.AsyncResourceModifiedSubmitterSvc

runDeliveryPass() - Method in class ca.uhn.fhir.jpa.subscription.triggering.SubscriptionTriggeringSvcImpl

S

scheduleJobs(ISchedulerService) - Method in class ca.uhn.fhir.jpa.subscription.async.AsyncResourceModifiedProcessingSchedulerSvc

scheduleJobs(ISchedulerService) - Method in class ca.uhn.fhir.jpa.subscription.triggering.SubscriptionTriggeringSvcImpl

SEARCH_EXPRESSION - Enum constant in enum ca.uhn.fhir.jpa.subscription.match.matcher.subscriber.SubscriptionCriteriaParser.TypeEnum

Normal search URL expression

send(EmailDetails) - Method in class ca.uhn.fhir.jpa.subscription.match.deliver.email.EmailSenderImpl

send(EmailDetails) - Method in interface ca.uhn.fhir.jpa.subscription.match.deliver.email.IEmailSender

sendNotification(ResourceDeliveryMessage) - Method in class ca.uhn.fhir.jpa.subscription.match.deliver.resthook.SubscriptionDeliveringRestHookSubscriber

Sends a POST notification without a payload

setBodyTemplate(String) - Method in class ca.uhn.fhir.jpa.subscription.match.deliver.email.EmailDetails

setDaoRegistryForUnitTest(DaoRegistry) - Method in class ca.uhn.fhir.jpa.subscription.match.deliver.BaseSubscriptionDeliverySubscriber

setDaoRegistryForUnitTest(DaoRegistry) - Method in class ca.uhn.fhir.jpa.subscription.submit.interceptor.SubscriptionValidatingInterceptor

setEmailSender(IEmailSender) - Method in class ca.uhn.fhir.jpa.subscription.match.deliver.email.SubscriptionDeliveringEmailSubscriber

setFhirContext(FhirContext) - Method in class ca.uhn.fhir.jpa.subscription.submit.interceptor.SubscriptionMatcherInterceptor

setFhirContext(FhirContext) - Method in class ca.uhn.fhir.jpa.subscription.submit.interceptor.SubscriptionValidatingInterceptor

setFhirContextForUnitTest(FhirContext) - Method in class ca.uhn.fhir.jpa.subscription.match.deliver.BaseSubscriptionDeliverySubscriber

setFlagForDeletion(boolean) - Method in class ca.uhn.fhir.jpa.subscription.match.registry.ActiveSubscription

setFrom(String) - Method in class ca.uhn.fhir.jpa.subscription.match.deliver.email.EmailDetails

setInterceptorBroadcasterForUnitTest(IInterceptorBroadcaster) - Method in class ca.uhn.fhir.jpa.subscription.match.deliver.BaseSubscriptionDeliverySubscriber

setMatchUrlServiceForUnitTest(MatchUrlService) - Method in class ca.uhn.fhir.jpa.subscription.match.deliver.BaseSubscriptionDeliverySubscriber

setMaxSubmitPerPass(Integer) - Method in class ca.uhn.fhir.jpa.subscription.triggering.SubscriptionTriggeringSvcImpl

Sets the maximum number of resources that will be submitted in a single pass

setRequestPartitionHelperSvcForUnitTest(IRequestPartitionHelperSvc) - Method in class ca.uhn.fhir.jpa.subscription.submit.interceptor.SubscriptionValidatingInterceptor

setRetryConfiguration(ChannelRetryConfiguration) - Method in class ca.uhn.fhir.jpa.subscription.channel.models.BaseChannelParameters

setRetryConfiguration(ChannelRetryConfiguration) - Method in class ca.uhn.fhir.jpa.subscription.match.registry.ActiveSubscription

setStorageSettingsForUnitTest(JpaStorageSettings) - Method in class ca.uhn.fhir.jpa.subscription.submit.interceptor.SubscriptionValidatingInterceptor

setSubjectTemplate(String) - Method in class ca.uhn.fhir.jpa.subscription.match.deliver.email.EmailDetails

setSubscription(CanonicalSubscription) - Method in class ca.uhn.fhir.jpa.subscription.match.registry.ActiveSubscription

setSubscription(IIdType) - Method in class ca.uhn.fhir.jpa.subscription.match.deliver.email.EmailDetails

setSubscriptionCanonicalizerForUnitTest(SubscriptionCanonicalizer) - Method in class ca.uhn.fhir.jpa.subscription.submit.interceptor.SubscriptionValidatingInterceptor

setSubscriptionRegistryForUnitTest(SubscriptionRegistry) - Method in class ca.uhn.fhir.jpa.subscription.match.deliver.BaseSubscriptionDeliverySubscriber

setSubscriptionStrategyEvaluatorForUnitTest(SubscriptionStrategyEvaluator) - Method in class ca.uhn.fhir.jpa.subscription.submit.interceptor.SubscriptionValidatingInterceptor

setTo(List<String>) - Method in class ca.uhn.fhir.jpa.subscription.match.deliver.email.EmailDetails

size() - Method in class ca.uhn.fhir.jpa.subscription.channel.subscription.SubscriptionChannelRegistry

size() - Method in class ca.uhn.fhir.jpa.subscription.match.registry.SubscriptionRegistry

size() - Method in class ca.uhn.fhir.jpa.topic.ActiveSubscriptionTopicCache

size() - Method in class ca.uhn.fhir.jpa.topic.SubscriptionTopicRegistry

start() - Method in class ca.uhn.fhir.jpa.subscription.submit.interceptor.SubscriptionSubmitInterceptorLoader

start() - Method in class ca.uhn.fhir.jpa.subscription.triggering.SubscriptionTriggeringSvcImpl

startIfNeeded() - Method in class ca.uhn.fhir.jpa.subscription.submit.svc.ResourceModifiedSubmitterSvc

STARTYPE_EXPRESSION - Enum constant in enum ca.uhn.fhir.jpa.subscription.match.matcher.subscriber.SubscriptionCriteriaParser.TypeEnum

All types

step10_resourceModified(ResourceModifiedMessage) - Method in class ca.uhn.fhir.jpa.subscription.util.SubscriptionDebugLogInterceptor

step20_beforeChecked(ResourceModifiedMessage) - Method in class ca.uhn.fhir.jpa.subscription.util.SubscriptionDebugLogInterceptor

step30_subscriptionMatched(ResourceDeliveryMessage, InMemoryMatchResult) - Method in class ca.uhn.fhir.jpa.subscription.util.SubscriptionDebugLogInterceptor

step35_subscriptionNotMatched(ResourceModifiedMessage) - Method in class ca.uhn.fhir.jpa.subscription.util.SubscriptionDebugLogInterceptor

step40_beforeDelivery(ResourceDeliveryMessage) - Method in class ca.uhn.fhir.jpa.subscription.util.SubscriptionDebugLogInterceptor

step45_deliveryFailed(ResourceDeliveryMessage, Exception) - Method in class ca.uhn.fhir.jpa.subscription.util.SubscriptionDebugLogInterceptor

step50_afterDelivery(ResourceDeliveryMessage) - Method in class ca.uhn.fhir.jpa.subscription.util.SubscriptionDebugLogInterceptor

stop() - Method in class ca.uhn.fhir.jpa.subscription.match.matcher.subscriber.MatchingQueueSubscriberLoader

submitPersisedResourceModifiedMessage(IPersistedResourceModifiedMessage) - Method in class ca.uhn.fhir.jpa.subscription.submit.svc.ResourceModifiedSubmitterSvc

This method will inflate the ResourceModifiedMessage represented by the IPersistedResourceModifiedMessage and attempts to submit it to the subscription processing pipeline.

submitResourceModified(ResourceModifiedMessage) - Method in class ca.uhn.fhir.jpa.subscription.submit.svc.ResourceModifiedSubmitterSvc

SUBS1 - Enum constant in enum ca.uhn.fhir.jpa.subscription.util.SubscriptionDebugLogInterceptor.EventCodeEnum

A new/updated resource has been submitted to the processing pipeline and is about to be placed on the matchign queue.

SUBS2 - Enum constant in enum ca.uhn.fhir.jpa.subscription.util.SubscriptionDebugLogInterceptor.EventCodeEnum

A resources has been dequeued from the matching queue and is about to be checked for any matching subscriptions.

SUBS3 - Enum constant in enum ca.uhn.fhir.jpa.subscription.util.SubscriptionDebugLogInterceptor.EventCodeEnum

The resource has matched a subscription (logged once for each matching subscription) and is about to be queued for delivery.

SUBS4 - Enum constant in enum ca.uhn.fhir.jpa.subscription.util.SubscriptionDebugLogInterceptor.EventCodeEnum

The resource did not match any subscriptions and processing is complete.

SUBS5 - Enum constant in enum ca.uhn.fhir.jpa.subscription.util.SubscriptionDebugLogInterceptor.EventCodeEnum

The resource has been dequeued from the delivery queue and is about to be delivered.

SUBS6 - Enum constant in enum ca.uhn.fhir.jpa.subscription.util.SubscriptionDebugLogInterceptor.EventCodeEnum

Delivery failed

SUBS7 - Enum constant in enum ca.uhn.fhir.jpa.subscription.util.SubscriptionDebugLogInterceptor.EventCodeEnum

Delivery is now complete and processing is finished.

subscribeToMatchingChannel() - Method in class ca.uhn.fhir.jpa.subscription.match.matcher.subscriber.MatchingQueueSubscriberLoader

SUBSCRIPTION_MATCHING_CHANNEL_NAME - Static variable in class ca.uhn.fhir.jpa.subscription.match.matcher.subscriber.SubscriptionMatchingSubscriber

subscriptionActivatingSubscriber() - Method in class ca.uhn.fhir.jpa.subscription.match.config.SubscriptionProcessorConfig

SubscriptionActivatingSubscriber - Class in ca.uhn.fhir.jpa.subscription.match.matcher.subscriber

Responsible for transitioning subscription resources from REQUESTED to ACTIVE Once activated, the subscription is added to the SubscriptionRegistry.

SubscriptionActivatingSubscriber() - Constructor for class ca.uhn.fhir.jpa.subscription.match.matcher.subscriber.SubscriptionActivatingSubscriber

Constructor

subscriptionCanonicalizer(FhirContext) - Method in class ca.uhn.fhir.jpa.subscription.model.config.SubscriptionModelConfig

subscriptionChannelRegistry() - Method in class ca.uhn.fhir.jpa.subscription.match.config.SubscriptionProcessorConfig

SubscriptionChannelRegistry - Class in ca.uhn.fhir.jpa.subscription.channel.subscription

SubscriptionChannelRegistry() - Constructor for class ca.uhn.fhir.jpa.subscription.channel.subscription.SubscriptionChannelRegistry

SubscriptionChannelWithHandlers - Class in ca.uhn.fhir.jpa.subscription.channel.subscription

SubscriptionChannelWithHandlers(String, SubscribableChannel) - Constructor for class ca.uhn.fhir.jpa.subscription.channel.subscription.SubscriptionChannelWithHandlers

SubscriptionCriteriaParser - Enum in ca.uhn.fhir.jpa.subscription.match.matcher.subscriber

SubscriptionCriteriaParser.SubscriptionCriteria - Class in ca.uhn.fhir.jpa.subscription.match.matcher.subscriber

SubscriptionCriteriaParser.TypeEnum - Enum in ca.uhn.fhir.jpa.subscription.match.matcher.subscriber

SubscriptionDebugLogInterceptor - Class in ca.uhn.fhir.jpa.subscription.util

This interceptor can be used for troubleshooting subscription processing.

SubscriptionDebugLogInterceptor() - Constructor for class ca.uhn.fhir.jpa.subscription.util.SubscriptionDebugLogInterceptor

Constructor that logs at INFO level to the logger ca.uhn.fhir.jpa.subscription.util.SubscriptionDebugLogInterceptor

SubscriptionDebugLogInterceptor(Function<SubscriptionDebugLogInterceptor.EventCodeEnum, Logger>, Level) - Constructor for class ca.uhn.fhir.jpa.subscription.util.SubscriptionDebugLogInterceptor

Constructor using a specific logger

SubscriptionDebugLogInterceptor.EventCodeEnum - Enum in ca.uhn.fhir.jpa.subscription.util

subscriptionDeliveringEmailSubscriber(IEmailSender) - Method in class ca.uhn.fhir.jpa.subscription.match.config.SubscriptionProcessorConfig

SubscriptionDeliveringEmailSubscriber - Class in ca.uhn.fhir.jpa.subscription.match.deliver.email

SubscriptionDeliveringEmailSubscriber(IEmailSender) - Constructor for class ca.uhn.fhir.jpa.subscription.match.deliver.email.SubscriptionDeliveringEmailSubscriber

subscriptionDeliveringMessageSubscriber(IChannelFactory) - Method in class ca.uhn.fhir.jpa.subscription.match.config.SubscriptionProcessorConfig

SubscriptionDeliveringMessageSubscriber - Class in ca.uhn.fhir.jpa.subscription.match.deliver.message

SubscriptionDeliveringMessageSubscriber(IChannelFactory) - Constructor for class ca.uhn.fhir.jpa.subscription.match.deliver.message.SubscriptionDeliveringMessageSubscriber

Constructor

subscriptionDeliveringRestHookSubscriber() - Method in class ca.uhn.fhir.jpa.subscription.match.config.SubscriptionProcessorConfig

SubscriptionDeliveringRestHookSubscriber - Class in ca.uhn.fhir.jpa.subscription.match.deliver.resthook

SubscriptionDeliveringRestHookSubscriber() - Constructor for class ca.uhn.fhir.jpa.subscription.match.deliver.resthook.SubscriptionDeliveringRestHookSubscriber

Constructor

subscriptionDeliveryChannelNamer() - Method in class ca.uhn.fhir.jpa.subscription.match.config.SubscriptionProcessorConfig

SubscriptionDeliveryChannelNamer - Class in ca.uhn.fhir.jpa.subscription.channel.subscription

SubscriptionDeliveryChannelNamer() - Constructor for class ca.uhn.fhir.jpa.subscription.channel.subscription.SubscriptionDeliveryChannelNamer

subscriptionDeliveryHandlerFactory(ApplicationContext, IEmailSender) - Method in class ca.uhn.fhir.jpa.subscription.match.config.SubscriptionProcessorConfig

SubscriptionDeliveryHandlerFactory - Class in ca.uhn.fhir.jpa.subscription.channel.subscription

SubscriptionDeliveryHandlerFactory(ApplicationContext, IEmailSender) - Constructor for class ca.uhn.fhir.jpa.subscription.channel.subscription.SubscriptionDeliveryHandlerFactory

SubscriptionDeliveryRequest - Class in ca.uhn.fhir.jpa.subscription.match.matcher.subscriber

SubscriptionDeliveryRequest(IBaseBundle, ActiveSubscription, SubscriptionTopicDispatchRequest) - Constructor for class ca.uhn.fhir.jpa.subscription.match.matcher.subscriber.SubscriptionDeliveryRequest

SubscriptionDeliveryRequest(IBaseResource, ResourceModifiedMessage, ActiveSubscription) - Constructor for class ca.uhn.fhir.jpa.subscription.match.matcher.subscriber.SubscriptionDeliveryRequest

SubscriptionDeliveryRequest(IIdType, ResourceModifiedMessage, ActiveSubscription) - Constructor for class ca.uhn.fhir.jpa.subscription.match.matcher.subscriber.SubscriptionDeliveryRequest

subscriptionLoader() - Method in class ca.uhn.fhir.jpa.subscription.match.config.SubscriptionProcessorConfig

SubscriptionLoader - Class in ca.uhn.fhir.jpa.subscription.match.registry

SubscriptionLoader() - Constructor for class ca.uhn.fhir.jpa.subscription.match.registry.SubscriptionLoader

Constructor

subscriptionMatchDeliverer(FhirContext, IInterceptorBroadcaster, SubscriptionChannelRegistry) - Method in class ca.uhn.fhir.jpa.subscription.match.config.SubscriptionProcessorConfig

SubscriptionMatchDeliverer - Class in ca.uhn.fhir.jpa.subscription.match.matcher.subscriber

SubscriptionMatchDeliverer(FhirContext, IInterceptorBroadcaster, SubscriptionChannelRegistry) - Constructor for class ca.uhn.fhir.jpa.subscription.match.matcher.subscriber.SubscriptionMatchDeliverer

subscriptionMatcher(DaoSubscriptionMatcher, InMemorySubscriptionMatcher) - Method in class ca.uhn.fhir.jpa.subscription.match.config.SubscriptionProcessorConfig

subscriptionMatcherInterceptor() - Method in class ca.uhn.fhir.jpa.subscription.submit.config.SubscriptionMatcherInterceptorConfig

SubscriptionMatcherInterceptor - Class in ca.uhn.fhir.jpa.subscription.submit.interceptor

This interceptor is responsible for submitting operations on resources to the subscription pipeline.

SubscriptionMatcherInterceptor() - Constructor for class ca.uhn.fhir.jpa.subscription.submit.interceptor.SubscriptionMatcherInterceptor

Constructor

SubscriptionMatcherInterceptorConfig - Class in ca.uhn.fhir.jpa.subscription.submit.config

SubscriptionMatcherInterceptorConfig() - Constructor for class ca.uhn.fhir.jpa.subscription.submit.config.SubscriptionMatcherInterceptorConfig

subscriptionMatcherInterceptorLoader() - Method in class ca.uhn.fhir.jpa.subscription.submit.config.SubscriptionSubmitterConfig

subscriptionMatchingSubscriber() - Method in class ca.uhn.fhir.jpa.subscription.match.config.SubscriptionProcessorConfig

SubscriptionMatchingSubscriber - Class in ca.uhn.fhir.jpa.subscription.match.matcher.subscriber

SubscriptionMatchingSubscriber() - Constructor for class ca.uhn.fhir.jpa.subscription.match.matcher.subscriber.SubscriptionMatchingSubscriber

Constructor

subscriptionMatchingSubscriberLoader() - Method in class ca.uhn.fhir.jpa.subscription.match.config.SubscriptionProcessorConfig

SubscriptionModelConfig - Class in ca.uhn.fhir.jpa.subscription.model.config

SubscriptionModelConfig() - Constructor for class ca.uhn.fhir.jpa.subscription.model.config.SubscriptionModelConfig

SubscriptionProcessorConfig - Class in ca.uhn.fhir.jpa.subscription.match.config

This Spring config should be imported by a system that pulls messages off of the matching queue for processing, and handles delivery

SubscriptionProcessorConfig() - Constructor for class ca.uhn.fhir.jpa.subscription.match.config.SubscriptionProcessorConfig

subscriptionQueryValidator(DaoRegistry, SubscriptionStrategyEvaluator) - Method in class ca.uhn.fhir.jpa.subscription.submit.config.SubscriptionSubmitterConfig

SubscriptionQueryValidator - Class in ca.uhn.fhir.jpa.subscription.submit.interceptor

SubscriptionQueryValidator(DaoRegistry, SubscriptionStrategyEvaluator) - Constructor for class ca.uhn.fhir.jpa.subscription.submit.interceptor.SubscriptionQueryValidator

subscriptionRegisteringSubscriber() - Method in class ca.uhn.fhir.jpa.subscription.match.config.SubscriptionProcessorConfig

SubscriptionRegisteringSubscriber - Class in ca.uhn.fhir.jpa.subscription.match.matcher.subscriber

Responsible for transitioning subscription resources from REQUESTED to ACTIVE Once activated, the subscription is added to the SubscriptionRegistry.

SubscriptionRegisteringSubscriber() - Constructor for class ca.uhn.fhir.jpa.subscription.match.matcher.subscriber.SubscriptionRegisteringSubscriber

Constructor

subscriptionRegistry() - Method in class ca.uhn.fhir.jpa.subscription.match.config.SubscriptionProcessorConfig

SubscriptionRegistry - Class in ca.uhn.fhir.jpa.subscription.match.registry

Cache of active subscriptions.

SubscriptionRegistry() - Constructor for class ca.uhn.fhir.jpa.subscription.match.registry.SubscriptionRegistry

Constructor

subscriptionStrategyEvaluator() - Method in class ca.uhn.fhir.jpa.subscription.model.config.SubscriptionModelConfig

SubscriptionStrategyEvaluator - Class in ca.uhn.fhir.jpa.subscription.match.matcher.matching

SubscriptionStrategyEvaluator() - Constructor for class ca.uhn.fhir.jpa.subscription.match.matcher.matching.SubscriptionStrategyEvaluator

Constructor

SubscriptionSubmitInterceptorLoader - Class in ca.uhn.fhir.jpa.subscription.submit.interceptor

SubscriptionSubmitInterceptorLoader() - Constructor for class ca.uhn.fhir.jpa.subscription.submit.interceptor.SubscriptionSubmitInterceptorLoader

SubscriptionSubmitterConfig - Class in ca.uhn.fhir.jpa.subscription.submit.config

This Spring config should be imported by a system that submits resources to the matching queue for processing

SubscriptionSubmitterConfig() - Constructor for class ca.uhn.fhir.jpa.subscription.submit.config.SubscriptionSubmitterConfig

SubscriptionTopicCanonicalizer - Class in ca.uhn.fhir.jpa.topic

SubscriptionTopicConfig - Class in ca.uhn.fhir.jpa.topic

SubscriptionTopicConfig() - Constructor for class ca.uhn.fhir.jpa.topic.SubscriptionTopicConfig

SubscriptionTopicDispatcher - Class in ca.uhn.fhir.jpa.topic

Subscription topic notifications are natively supported in R5, R4B.

SubscriptionTopicDispatcher(FhirContext, SubscriptionRegistry, SubscriptionMatchDeliverer, SubscriptionTopicPayloadBuilder) - Constructor for class ca.uhn.fhir.jpa.topic.SubscriptionTopicDispatcher

SubscriptionTopicDispatchRequest - Class in ca.uhn.fhir.jpa.topic

SubscriptionTopicDispatchRequest(String, List<IBaseResource>, ISubscriptionTopicFilterMatcher, RestOperationTypeEnum, InMemoryMatchResult, RequestPartitionId, String) - Constructor for class ca.uhn.fhir.jpa.topic.SubscriptionTopicDispatchRequest

SubscriptionTopicFilterUtil - Class in ca.uhn.fhir.jpa.topic.filter

SubscriptionTopicLoader - Class in ca.uhn.fhir.jpa.topic

SubscriptionTopicLoader() - Constructor for class ca.uhn.fhir.jpa.topic.SubscriptionTopicLoader

Constructor

SubscriptionTopicMatcher - Class in ca.uhn.fhir.jpa.topic

SubscriptionTopicMatcher(SubscriptionTopicSupport, SubscriptionTopic) - Constructor for class ca.uhn.fhir.jpa.topic.SubscriptionTopicMatcher

SubscriptionTopicMatchingSubscriber - Class in ca.uhn.fhir.jpa.topic

SubscriptionTopicMatchingSubscriber(FhirContext) - Constructor for class ca.uhn.fhir.jpa.topic.SubscriptionTopicMatchingSubscriber

SubscriptionTopicPayloadBuilder - Class in ca.uhn.fhir.jpa.topic

SubscriptionTopicPayloadBuilder(FhirContext) - Constructor for class ca.uhn.fhir.jpa.topic.SubscriptionTopicPayloadBuilder

SubscriptionTopicRegisteringSubscriber - Class in ca.uhn.fhir.jpa.topic

Responsible for transitioning subscription resources from REQUESTED to ACTIVE Once activated, the subscription is added to the SubscriptionRegistry.

SubscriptionTopicRegisteringSubscriber() - Constructor for class ca.uhn.fhir.jpa.topic.SubscriptionTopicRegisteringSubscriber

Constructor

SubscriptionTopicRegistry - Class in ca.uhn.fhir.jpa.topic

SubscriptionTopicRegistry() - Constructor for class ca.uhn.fhir.jpa.topic.SubscriptionTopicRegistry

SubscriptionTopicSupport - Class in ca.uhn.fhir.jpa.topic

SubscriptionTopicSupport(FhirContext, DaoRegistry, SearchParamMatcher) - Constructor for class ca.uhn.fhir.jpa.topic.SubscriptionTopicSupport

SubscriptionTopicUtil - Class in ca.uhn.fhir.jpa.topic

SubscriptionTopicUtil() - Constructor for class ca.uhn.fhir.jpa.topic.SubscriptionTopicUtil

SubscriptionTopicValidatingInterceptor - Class in ca.uhn.fhir.jpa.topic

SubscriptionTopicValidatingInterceptor(FhirContext, SubscriptionQueryValidator) - Constructor for class ca.uhn.fhir.jpa.topic.SubscriptionTopicValidatingInterceptor

subscriptionTriggeringSvc() - Method in class ca.uhn.fhir.jpa.subscription.submit.config.SubscriptionSubmitterConfig

SubscriptionTriggeringSvcImpl - Class in ca.uhn.fhir.jpa.subscription.triggering

SubscriptionTriggeringSvcImpl() - Constructor for class ca.uhn.fhir.jpa.subscription.triggering.SubscriptionTriggeringSvcImpl

SubscriptionTriggeringSvcImpl.Job - Class in ca.uhn.fhir.jpa.subscription.triggering

SubscriptionTriggerMatcher - Class in ca.uhn.fhir.jpa.topic

SubscriptionTriggerMatcher(SubscriptionTopicSupport, ResourceModifiedMessage, SubscriptionTopic.SubscriptionTopicResourceTriggerComponent) - Constructor for class ca.uhn.fhir.jpa.topic.SubscriptionTriggerMatcher

SubscriptionUtil - Class in ca.uhn.fhir.jpa.subscription.util

Utilities for working with the subscription resource

SubscriptionUtil() - Constructor for class ca.uhn.fhir.jpa.subscription.util.SubscriptionUtil

subscriptionValidatingInterceptor() - Method in class ca.uhn.fhir.jpa.subscription.submit.config.SubscriptionSubmitterConfig

SubscriptionValidatingInterceptor - Class in ca.uhn.fhir.jpa.subscription.submit.interceptor

SubscriptionValidatingInterceptor() - Constructor for class ca.uhn.fhir.jpa.subscription.submit.interceptor.SubscriptionValidatingInterceptor

subscriptionWebSocketHandler() - Method in class ca.uhn.fhir.jpa.subscription.match.config.WebsocketDispatcherConfig

SubscriptionWebsocketHandler - Class in ca.uhn.fhir.jpa.subscription.match.deliver.websocket

SubscriptionWebsocketHandler() - Constructor for class ca.uhn.fhir.jpa.subscription.match.deliver.websocket.SubscriptionWebsocketHandler

Constructor

SynchronousSubscriptionMatcherInterceptor - Class in ca.uhn.fhir.jpa.subscription.submit.interceptor

The purpose of this interceptor is to synchronously submit ResourceModifiedMessage to the subscription processing pipeline, ie, as part of processing the operation on a resource.

SynchronousSubscriptionMatcherInterceptor() - Constructor for class ca.uhn.fhir.jpa.subscription.submit.interceptor.SynchronousSubscriptionMatcherInterceptor

syncResourcesIntoCache(List<IBaseResource>) - Method in class ca.uhn.fhir.jpa.subscription.match.registry.SubscriptionLoader

syncResourcesIntoCache(List<IBaseResource>) - Method in class ca.uhn.fhir.jpa.topic.SubscriptionTopicLoader

syncSubscriptions() - Method in class ca.uhn.fhir.jpa.subscription.match.registry.SubscriptionLoader

T

toEmail() - Method in class ca.uhn.fhir.jpa.subscription.match.deliver.email.EmailDetails

toString() - Method in class ca.uhn.fhir.jpa.subscription.match.matcher.subscriber.SubscriptionCriteriaParser.SubscriptionCriteria

triggerSubscription(List<IPrimitiveType<String>>, List<IPrimitiveType<String>>, IIdType) - Method in class ca.uhn.fhir.jpa.subscription.triggering.SubscriptionTriggeringSvcImpl

U

unregister(String) - Method in class ca.uhn.fhir.jpa.topic.SubscriptionTopicRegistry

unregisterAllIdsNotInCollection(Set<String>) - Method in class ca.uhn.fhir.jpa.topic.SubscriptionTopicRegistry

unregisterAllSubscriptions() - Method in class ca.uhn.fhir.jpa.subscription.match.registry.SubscriptionRegistry

unregisterInterceptorsForUnitTest() - Method in class ca.uhn.fhir.jpa.subscription.submit.interceptor.SubscriptionSubmitInterceptorLoader

unregisterSubscriptionIfRegistered(String) - Method in class ca.uhn.fhir.jpa.subscription.match.registry.SubscriptionRegistry

V

VALID_RESPONSE(ActiveSubscription) - Static method in class ca.uhn.fhir.jpa.subscription.match.deliver.websocket.WebsocketValidationResponse

validate(IdType) - Method in class ca.uhn.fhir.jpa.subscription.match.deliver.websocket.WebsocketConnectionValidator

validateChannelEndpoint(CanonicalSubscription) - Method in class ca.uhn.fhir.jpa.subscription.submit.interceptor.SubscriptionValidatingInterceptor

validateChannelPayload(CanonicalSubscription) - Method in class ca.uhn.fhir.jpa.subscription.submit.interceptor.SubscriptionValidatingInterceptor

validateChannelType(CanonicalSubscription) - Method in class ca.uhn.fhir.jpa.subscription.submit.interceptor.SubscriptionValidatingInterceptor

validateCriteria(String, String) - Method in class ca.uhn.fhir.jpa.subscription.submit.interceptor.SubscriptionQueryValidator

validateCriteria(String, String) - Method in class ca.uhn.fhir.jpa.topic.SubscriptionTopicValidatingInterceptor

validateMessageSubscriptionEndpoint(String) - Method in class ca.uhn.fhir.jpa.subscription.submit.interceptor.SubscriptionValidatingInterceptor

validatePermissions(IBaseResource, CanonicalSubscription, RequestDetails, RequestPartitionId, Pointcut) - Method in class ca.uhn.fhir.jpa.subscription.submit.interceptor.SubscriptionValidatingInterceptor

validateQuery(String, String) - Method in class ca.uhn.fhir.jpa.subscription.submit.interceptor.SubscriptionValidatingInterceptor

valueOf(String) - Static method in enum ca.uhn.fhir.jpa.subscription.match.matcher.subscriber.SubscriptionCriteriaParser.TypeEnum

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum ca.uhn.fhir.jpa.subscription.match.matcher.subscriber.SubscriptionCriteriaParser

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum ca.uhn.fhir.jpa.subscription.util.SubscriptionDebugLogInterceptor.EventCodeEnum

Returns the enum constant of this type with the specified name.

values() - Static method in enum ca.uhn.fhir.jpa.subscription.match.matcher.subscriber.SubscriptionCriteriaParser.TypeEnum

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum ca.uhn.fhir.jpa.subscription.match.matcher.subscriber.SubscriptionCriteriaParser

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum ca.uhn.fhir.jpa.subscription.util.SubscriptionDebugLogInterceptor.EventCodeEnum

Returns an array containing the constants of this enum type, in the order they are declared.

W

websocketConnectionValidator() - Method in class ca.uhn.fhir.jpa.subscription.match.config.WebsocketDispatcherConfig

WebsocketConnectionValidator - Class in ca.uhn.fhir.jpa.subscription.match.deliver.websocket

WebsocketConnectionValidator() - Constructor for class ca.uhn.fhir.jpa.subscription.match.deliver.websocket.WebsocketConnectionValidator

Constructor

WebsocketDispatcherConfig - Class in ca.uhn.fhir.jpa.subscription.match.config

WebsocketDispatcherConfig() - Constructor for class ca.uhn.fhir.jpa.subscription.match.config.WebsocketDispatcherConfig

WebsocketValidationResponse - Class in ca.uhn.fhir.jpa.subscription.match.deliver.websocket

A B C D E G H I J L M N P R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values