public static DistributionAgentState getState()

in src/main/java/org/apache/sling/distribution/journal/impl/publisher/AgentState.java [45:55]

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

    public static DistributionAgentState getState(DistributionAgent agent) {
        boolean empty = queueStatuses(agent).noneMatch(AgentState::queueNotEmpty);
        if (empty) {
            return IDLE;
        }
        boolean blocked = queueStatuses(agent).anyMatch(AgentState::isBlocked);
        if (blocked) {
            return BLOCKED;
        }
        return RUNNING;
    }