public DistributionResponse execute()

in src/main/java/org/apache/sling/distribution/journal/impl/publisher/DistributionPublisher.java [205:218]

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

    public DistributionResponse execute(ResourceResolver resourceResolver,
                                        DistributionRequest request)
            throws DistributionException {
        if (request.getRequestType() == PULL) {
            String msg = "Request requestType=PULL not supported by this agent";
            distLog.info(msg);
            return new SimpleDistributionResponse(DistributionRequestState.DROPPED, msg);
        }
        int queueSize = pubQueueProvider.getMaxQueueSize(pubAgentName);
        int sleepMs = getSleepTime(queueSize);
        sleep(sleepMs);
        final PackageMessage pkg = buildPackage(resourceResolver, request);
        return send(pkg, queueSize, sleepMs);
    }