public void handleInitialOffset()

in src/main/java/org/apache/sling/distribution/journal/bookkeeper/BookKeeper.java [382:394]

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

    public void handleInitialOffset(long offset) {
        try (ResourceResolver resolver = getServiceResolver(SUBSERVICE_BOOKKEEPER)) {
            long currentOffset = loadOffset();
            if (currentOffset == -1) {
                log.info("Storing initial offset. packageNodeName={}, subagentName={}, offset={}", 
                        config.getPackageNodeName(), config.getSubAgentName(), offset);
                storeOffset(resolver, offset);
                resolver.commit();
            }
        } catch (Exception e) {
            log.warn("Error storing initial offset={}", offset, e);
        }
    }