java - 直接执行 Camel 路线

Question

我最近接手了一些Java代码，有一个方法接收一个对象，并根据该对象的一些属性，对该对象执行一些处理。

我正在使用 Apache Camel，并且能够定义一条完成相同任务的路线。我挣扎的地方是，如何找到将对象传递到路由并执行逻辑的最简单方法？我现在拥有的是

producerTemplate.sendBody("direct:blah", myObject) 

并且路由本身定义了

from("direct:blah").process(...)

以上工作正常，尽管比以前慢了一点。

这是替换方法逻辑的最简单方法吗？我希望能够获取路由本身并将一个对象传递给它来执行，但我没有看到任何方法可以做到这一点。

Answer 1

您不一定需要 from().process()。您还可以将端点注入(inject)到您的方法中。例如:

@Consume(uri = "direct:blah")
public void onFileSendToQueue(String body, @Header("CamelFileName") String name) {
    LOG.info("Incoming file: {}", name);
    producer.sendBody(body);
}

您也可以为生产者做同样的事情。有关更多详细信息，请参阅 Camel pojo 消息传递。 http://camel.apache.org/pojo-messaging-example.html