private DiscoveryMessage createDiscoveryMessage()

in src/main/java/org/apache/sling/distribution/journal/impl/subscriber/Announcer.java [91:107]

• 17 lines of code
• 1 McCabe index (conditional complexity)

    private DiscoveryMessage createDiscoveryMessage() {
        long offset = bookKeeper.loadOffset();
        SubscriberConfig subscriberConfiguration = SubscriberConfig.builder()
                .editable(editable)
                .maxRetries(maxRetries)
                .build();
        List<SubscriberState> states = pubAgentNames.stream()
            .map(pubAgentName -> subscriberState(pubAgentName, offset))
            .collect(Collectors.toList());
        return DiscoveryMessage
                .builder()
                .subSlingId(subSlingId)
                .subAgentName(subAgentName)
                .subscriberConfiguration(subscriberConfiguration)
                .subscriberStates(states)
                .build();
    }