是否可以在 process() 中启动骆驼端点

Question

正如标题所说：是否可以在路由（-builder）的流程功能中启动骆驼端点？我是 apache camel 的新手，但已经做过一些项目。

情况如下： 我将 apache camel 与 Siemens Teamcenter RAC 结合使用来执行 SavedQuery。结果是带有找到的元素的 ModelObject[]。

对于这些元素中的每一个，我现在需要启动另一个端点来执行第二个搜索查询。我想到了类似的东西：

//within .process()
for (ModelObject ob : arrModelObjects) {
    // something like:  .to("direct:searchnew")
}

但我不能在处理器中引用外部函数“.to()”。是否有解决方法或解决方案，或者我想错了？

Answer 1

正如@Rathna 所说，您可以使用 producerTemplate。

您可以从您的上下文创建一个新的生产者模板，您可以从您的交换中获取如下：

public class MyProcessor implements Processor{

@Override
public void process(Exchange exchange) throws Exception {
    ProducerTemplate producerTemplate = exchange.getContext().createProducerTemplate();

    ModelObject[] arrModelObjects = (ModelObject[]) exchange.getIn().getBody();

    for (ModelObject ob : arrModelObjects) {
        producerTemplate.sendBody("direct:someEndpoint", ob);
    }
}

}

Answer 2

   class MyProcessor implements Processor{

    private ProducerTemplate producerTemplate;
      @Override
      public void process(Exchange exchange) throws Exception {
         for (ModelObject ob : arrModelObjects) {
               producerTemplate.send("direct:searchnew",exchange);    
       }}
    }

将 producerTemplate 添加到 CamelContext。