Package ca.uhn.fhir.jpa.subscription.submit.config

Class SubscriptionSubmitterConfig

java.lang.Object

ca.uhn.fhir.jpa.subscription.submit.config.SubscriptionSubmitterConfig

@Configuration
@Import({SubscriptionModelConfig.class,SubscriptionMatcherInterceptorConfig.class,SubscriptionConfig.class})
public class SubscriptionSubmitterConfig
extends Object

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

Constructor Summary

Constructors

Constructor	Description
SubscriptionSubmitterConfig()

Method Summary

Modifier and Type	Method	Description
AsyncResourceModifiedProcessingSchedulerSvc	asyncResourceModifiedProcessingSchedulerSvc(SubscriptionConfig subscriptionConfig, SubscriptionSettings theSubscriptionSettings)
AsyncResourceModifiedSubmitterSvc	asyncResourceModifiedSubmitterSvc(IResourceModifiedMessagePersistenceSvc theIResourceModifiedMessagePersistenceSvc, IResourceModifiedConsumerWithRetries theResourceModifiedConsumer)
ResourceModifiedSubmitterSvc	resourceModifiedSvc(IHapiTransactionService theHapiTransactionService, IResourceModifiedMessagePersistenceSvc theResourceModifiedMessagePersistenceSvc, SubscriptionChannelFactory theSubscriptionChannelFactory, SubscriptionSettings theSubscriptionSettings)
IChannelTypeValidator	restHookChannelValidator(SubscriptionSettings theSubscriptionSettings)
SubscriptionChannelTypeValidatorFactory	subscriptionChannelTypeValidatorFactory(List<IChannelTypeValidator> theValidorList)
SubscriptionSubmitInterceptorLoader	subscriptionMatcherInterceptorLoader(ca.uhn.fhir.interceptor.api.IInterceptorService theInterceptorService, SubscriptionSettings theSubscriptionSettings, SubscriptionMatcherInterceptor theSubscriptionMatcherInterceptor, SubscriptionValidatingInterceptor theSubscriptionValidatingInterceptor, SubscriptionTopicValidatingInterceptor theSubscriptionTopicValidatingInterceptor)
ISubscriptionTriggeringSvc	subscriptionTriggeringSvc()
SubscriptionValidatingInterceptor	subscriptionValidatingInterceptor()

Methods inherited from class java.lang.Object

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

Constructor Details

SubscriptionSubmitterConfig

public SubscriptionSubmitterConfig()

Method Details

subscriptionValidatingInterceptor

@Bean
public SubscriptionValidatingInterceptor subscriptionValidatingInterceptor()

subscriptionMatcherInterceptorLoader

@Bean
public SubscriptionSubmitInterceptorLoader subscriptionMatcherInterceptorLoader(@Nonnull
 ca.uhn.fhir.interceptor.api.IInterceptorService theInterceptorService,
 @Nonnull
 SubscriptionSettings theSubscriptionSettings,
 @Nonnull
 SubscriptionMatcherInterceptor theSubscriptionMatcherInterceptor,
 @Nonnull
 SubscriptionValidatingInterceptor theSubscriptionValidatingInterceptor,
 @Nullable
 SubscriptionTopicValidatingInterceptor theSubscriptionTopicValidatingInterceptor)

subscriptionTriggeringSvc

@Bean
@Lazy
public ISubscriptionTriggeringSvc subscriptionTriggeringSvc()

resourceModifiedSvc

@Bean
public ResourceModifiedSubmitterSvc resourceModifiedSvc(IHapiTransactionService theHapiTransactionService,
 IResourceModifiedMessagePersistenceSvc theResourceModifiedMessagePersistenceSvc,
 SubscriptionChannelFactory theSubscriptionChannelFactory,
 SubscriptionSettings theSubscriptionSettings)

asyncResourceModifiedProcessingSchedulerSvc

@Bean
public AsyncResourceModifiedProcessingSchedulerSvc asyncResourceModifiedProcessingSchedulerSvc(SubscriptionConfig subscriptionConfig,
 SubscriptionSettings theSubscriptionSettings)

asyncResourceModifiedSubmitterSvc

@Bean
public AsyncResourceModifiedSubmitterSvc asyncResourceModifiedSubmitterSvc(IResourceModifiedMessagePersistenceSvc theIResourceModifiedMessagePersistenceSvc,
 IResourceModifiedConsumerWithRetries theResourceModifiedConsumer)

restHookChannelValidator

@Bean
public IChannelTypeValidator restHookChannelValidator(SubscriptionSettings theSubscriptionSettings)

subscriptionChannelTypeValidatorFactory

@Bean
public SubscriptionChannelTypeValidatorFactory subscriptionChannelTypeValidatorFactory(List<IChannelTypeValidator> theValidorList)