public void apply()

in camel-k-resume-kafka/impl/src/main/java/org/apache/camel/k/resume/ResumeContextCustomizer.java [39:57]

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

    public void apply(CamelContext camelContext) {
        LOG.debug("Receiving context for customization");
        LOG.debug("Resume strategy: {}", resumeStrategy);
        LOG.debug("Resume server: {}", resumeServer);
        LOG.debug("Resume path: {}", resumePath);
        LOG.debug("Cache fill policy: {}", cacheFillPolicy);

        ResumeCache<?> resumeCache = (ResumeCache<?>) camelContext.getRegistry().lookupByName("cache");
        LOG.debug("Values from the registry (cache): {}", resumeCache);

        try {
            ResumeStrategy resumeStrategyInstance = KafkaResumeFactory.build(resumeStrategy, resumeServer, resumePath, cacheFillPolicy);

            LOG.debug("Created resume strategy instance: {}", resumeStrategyInstance.getClass());
            camelContext.getRegistry().bind("resumeStrategy", resumeStrategyInstance);
        } catch (Exception e) {
            LOG.error("Exception: {}", e.getMessage(), e);
        }
    }