public static ResumeStrategy build()

in camel-k-resume-kafka/impl/src/main/java/org/apache/camel/k/resume/kafka/KafkaResumeFactory.java [33:50]

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

    public static ResumeStrategy build(String name, String resumeServer, String topic, String cacheFillPolicy) {
        Cacheable.FillPolicy policy = extracted(cacheFillPolicy);

        final KafkaResumeStrategyConfiguration resumeStrategyConfiguration = KafkaResumeStrategyConfigurationBuilder.newBuilder()
                .withBootstrapServers(resumeServer)
                .withCacheFillPolicy(policy)
                .withTopic(topic)
                .build();

        switch (name) {
            case "org.apache.camel.processor.resume.kafka.SingleNodeKafkaResumeStrategy": {
                return new SingleNodeKafkaResumeStrategy(resumeStrategyConfiguration);
            }
            default: {
                throw new UnsupportedOperationException(String.format("The strategy %s is not a valid strategy", name));
            }
        }
    }