java - @Service 和 @Repository bean 未在 Spring boot 和 Apache Camel 中初始化

Question

在我的camel和spring boot应用程序中，我有一个简单的路线:文件夹->处理器->文件夹。

在处理器中，服务和存储库始终为空。在测试类中，这些不为空。

@Override
public void configure() throws Exception
{
    from("file:input")
    .log("from file")
    .process(new MyProcessor())
    .to("file:destination")
    .log("to destination")`
    .end();
}

我错过了什么吗？为什么存储库和服务 bean 在处理器中为空，但在测试类中工作正常。

Answer 1

您正在通过 new MyProcessor() 手动创建处理器，这意味着 Spring 不会为您 Autowiring 依赖项。

您应该使用Camel Bean support相反:

@Override
public void configure() throws Exception
{
    from("file:input")
    .log("from file")
    .bean("myProcessor")
    .to("file:destination")
    .log("to destination")`
    .end();
}

或者，如果您的 MyProcessor bean 实现了 Camel 的 Processor，您可以执行如下操作:

@Autowired
private MyProcessor processor;

@Override
public void configure() throws Exception
{
    from("file:input")
    .log("from file")
    .processor(processor)
    .to("file:destination")
    .log("to destination")`
    .end();
}