public DistributionAgentState getState()

in src/main/java/org/apache/sling/distribution/journal/impl/subscriber/DistributionSubscriber.java [265:271]

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

    public DistributionAgentState getState() {
        boolean isBlocked = bookKeeper.getPackageRetries().getSum() > 0;
        if (isBlocked) {
            return DistributionAgentState.BLOCKED;
        }
        return messageBuffer.size() > 0 ? DistributionAgentState.RUNNING : DistributionAgentState.IDLE;
    }