private void removeFailedPackage()

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

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

    private void removeFailedPackage(PackageMessage pkgMsg, long offset) throws DistributionException {
        log.info("Removing failed distribution package {} at offset={}", pkgMsg, offset);
        Timer.Context context = distributionMetricsService.getRemovedFailedPackageDuration().time();
        try (ResourceResolver resolver = getServiceResolver(SUBSERVICE_BOOKKEEPER)) {
            storeStatus(resolver, new PackageStatus(Status.REMOVED_FAILED, offset, pkgMsg.getPubAgentName()));
            storeOffset(resolver, offset);
            resolver.commit();
        } catch (Exception e) {
            throw new DistributionException("Error removing failed package", e);
        }
        context.stop();
        distributionMetricsService.getPackageStatusCounter(Status.REMOVED_FAILED.name()).increment();
    }