public void update()

in src/main/java/org/apache/sling/jobs/impl/OutboundJobUpdateListener.java [50:61]

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

    public void update(@NotNull JobUpdate update) {
        if ( active ) {
            switch(update.getCommand()) {
                case START_JOB:
                    queueManager.add(update.getQueue().asQueueName(), Utils.toMapValue(update));
                    break;
                default:
                    topicManager.publish(update.getQueue().asTopicName(), update.getCommand().asCommandName(), Utils.toMapValue(update));
                    break;
            }
        }
    }