public PackageDistributedNotifier()

in src/main/java/org/apache/sling/distribution/journal/impl/publisher/PackageDistributedNotifier.java [79:93]

• 13 lines of code
• 2 McCabe index (conditional complexity)

    public PackageDistributedNotifier(EventAdmin eventAdmin, PubQueueProvider pubQueueCacheService, MessagingProvider messagingProvider, Topics topics, ResourceResolverFactory resolverFactory, boolean ensureEvent) {
        this.eventAdmin = eventAdmin;
        this.pubQueueCacheService = pubQueueCacheService;
        this.messagingProvider = messagingProvider;
        this.topics = topics;
        this.resolverFactory = resolverFactory;
        this.ensureEvent = ensureEvent;

        sendMsg = StringUtils.isNotBlank(topics.getEventTopic());
        if (sendMsg) {
            sender = messagingProvider.createSender(topics.getEventTopic());
        }

        LOG.info("Started package distributed notifier with event message topic {}", topics.getEventTopic());
    }