in src/main/java/org/apache/sling/distribution/journal/impl/publisher/DistributedEventNotifierManager.java [73:89]
public DistributedEventNotifierManager(
BundleContext context,
Configuration config,
@Reference EventAdmin eventAdmin,
@Reference PubQueueProvider pubQueueCacheService,
@Reference MessagingProvider messagingProvider,
@Reference Topics topics,
@Reference ResourceResolverFactory resolverFactory,
@Reference EventHandler distributedEventHandler
) {
this.context = context;
this.config = config;
this.notifier = new PackageDistributedNotifier(eventAdmin, pubQueueCacheService, messagingProvider, topics, resolverFactory, config.ensureEvent());
if (! config.deduplicateEvent()) {
registerService();
}
}