public void removePackage()

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

15 lines of code
2 McCabe index (conditional complexity)


    public void removePackage(PackageMessage pkgMsg, long offset) throws LoginException, PersistenceException {
        log.info("Removing distribution package {} of type {} at offset {}", 
                pkgMsg.getPkgId(), pkgMsg.getReqType(), offset);
        Timer.Context context = subscriberMetrics.getRemovedPackageDuration().time();
        try (ResourceResolver resolver = getServiceResolver(SUBSERVICE_BOOKKEEPER)) {
            if (config.isEditable()) {
                storeStatus(resolver, new PackageStatus(Status.REMOVED, offset, pkgMsg.getPubAgentName()));
            }
            storeOffset(resolver, offset);
            resolver.commit();
        }
        packageRetries.clear(pkgMsg.getPubAgentName());
        context.stop();
        subscriberMetrics.getPackageStatusCounter(pkgMsg.getPubAgentName(), Status.REMOVED).increment();
    }