One more bit of extensibility

This commit is contained in:
jamesagnew 2019-11-02 19:03:46 -04:00
parent f7ad82d7a8
commit 2bf578879a
2 changed files with 7 additions and 2 deletions

View File

@ -26,6 +26,7 @@ import ca.uhn.fhir.jpa.search.cache.ISearchCacheSvc;
import ca.uhn.fhir.jpa.search.cache.ISearchResultCacheSvc; import ca.uhn.fhir.jpa.search.cache.ISearchResultCacheSvc;
import ca.uhn.fhir.jpa.search.reindex.IResourceReindexingSvc; import ca.uhn.fhir.jpa.search.reindex.IResourceReindexingSvc;
import ca.uhn.fhir.jpa.search.reindex.ResourceReindexingSvcImpl; import ca.uhn.fhir.jpa.search.reindex.ResourceReindexingSvcImpl;
import ca.uhn.fhir.jpa.subscription.SubscriptionActivatingInterceptor;
import ca.uhn.fhir.jpa.subscription.dbmatcher.CompositeInMemoryDaoSubscriptionMatcher; import ca.uhn.fhir.jpa.subscription.dbmatcher.CompositeInMemoryDaoSubscriptionMatcher;
import ca.uhn.fhir.jpa.subscription.dbmatcher.DaoSubscriptionMatcher; import ca.uhn.fhir.jpa.subscription.dbmatcher.DaoSubscriptionMatcher;
import ca.uhn.fhir.jpa.subscription.module.cache.LinkedBlockingQueueSubscribableChannelFactory; import ca.uhn.fhir.jpa.subscription.module.cache.LinkedBlockingQueueSubscribableChannelFactory;
@ -134,6 +135,11 @@ public abstract class BaseConfig {
return new SubscriptionTriggeringProvider(); return new SubscriptionTriggeringProvider();
} }
@Bean
public SubscriptionActivatingInterceptor subscriptionActivatingInterceptor() {
return new SubscriptionActivatingInterceptor();
}
@Bean(name = "myAttachmentBinaryAccessProvider") @Bean(name = "myAttachmentBinaryAccessProvider")
@Lazy @Lazy
public BinaryAccessProvider binaryAccessProvider() { public BinaryAccessProvider binaryAccessProvider() {

View File

@ -74,9 +74,8 @@ import static org.apache.commons.lang3.StringUtils.isBlank;
* <p> * <p>
* Also validates criteria. If invalid, rejects the subscription without persisting the subscription. * Also validates criteria. If invalid, rejects the subscription without persisting the subscription.
*/ */
@Service
@Lazy @Lazy
@Interceptor() @Interceptor
public class SubscriptionActivatingInterceptor { public class SubscriptionActivatingInterceptor {
private static boolean ourWaitForSubscriptionActivationSynchronouslyForUnitTest; private static boolean ourWaitForSubscriptionActivationSynchronouslyForUnitTest;
private Logger ourLog = LoggerFactory.getLogger(SubscriptionActivatingInterceptor.class); private Logger ourLog = LoggerFactory.getLogger(SubscriptionActivatingInterceptor.class);