Camel-K 不识别本地包

Camel-K does not recognize local package(Camel-K 不识别本地包)

问题描述

我有一个使用自己的处理器的 RouteBuilder 类.使用 Maven 在 Camel 中本地运行时，它运行良好.但是，当我尝试使用 camel-k 时，它说找不到包.我有什么需要做的吗?

I have a RouteBuilder class that is using its own Processor. When running locally in Camel using Maven, it runs fine. However, when I try to use camel-k, it says it cannot find the package. Is there something I need to do?

我的处理器

package com.test.processor;

import java.io.File;

import org.apache.camel.Exchange;
import org.apache.camel.Message;
import org.apache.camel.Processor;
import org.apache.camel.component.file.GenericFile;

public class MyProcessor implements Processor {

    public void process(Exchange exchange) throws Exception {
        Message inMsg = exchange.getIn();
        Object body = inMsg.getBody();
        
        if (body instanceof File) {
            System.out.println("Is a FILE");
        } else {
            System.out.println("Not a FILE");   
        }
        
        if (body instanceof GenericFile) {
            System.out.println("Is a GF for sure");
            GenericFile gf = (GenericFile) body;
            String fileName = gf.getFileName();
            
            System.out.println("Filename: " + fileName);
        } else {
            System.out.println("NOT a GF");
        }
    }
}

路由器

package com.javainuse.route;

import org.apache.camel.builder.RouteBuilder;
import com.test.processor.MyProcessor;

public class SimpleRouteBuilder extends RouteBuilder {

    @Override
    public void configure() throws Exception {
        // Transfer files from one another using a processor
        from("file:C:/inputFolder?noop=true")
            .process(new MyProcessor())
            .to("file:C:/outputFolder")
            .setBody().simple("Test")
            .log("Test log");
    }
}

我正在使用 minikube 并运行命令:kamel 运行 SimpleRouteBuilder.java --dev

I am using minikube and run the command: kamel run SimpleRouteBuilder.java --dev

[1] Exception in thread "main" org.apache.camel.RuntimeCamelException: org.joor.ReflectException: Compilation error: /com/test/route/SimpleRouteBuilder.java:4: error: package com.test.processor does not exist
[1] import com.test.processor.MyProcessor;

推荐答案

这是意料之中的，因为 camel-k 不知道在哪里可以找到您的处理器的类，所以您有两个选择:

This is expected as camel-k does not know where to find the classes for your processor so you have two options:

1. 将处理器嵌入到路由的内部类中
2. 将您的处理器打包为 maven 工件(您也可以使用 jitpack 以避免在测试时将其发布到 maven 存储库)并将其列为任何其他依赖项

这篇关于Camel-K 不识别本地包的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持编程学习网！