是否可以在进程（）中启动骆驼endpoint

Question

正如标题所说：是否可以在路由（-builder）的流程功能中启动一个驼峰endpoint？我刚接触apache camel，但已经做了一些项目。

情况如下：我正在使用apache camel和西门子Teamcenter RAC执行一个SavedQuery。结果是一个ModelObject[]和找到的元素。

对于这些元素中的每一个，我现在需要启动另一个endpoint，执行第二个搜索查询。我想到了这样的事情：

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

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

Answer 1

   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添加到上下文中。

Answer 2

正如@Rathna提到的，您可以使用producerTemboard。

您可以根据您的上下文创建一个新的生产者模板，您可以从exchange获得该模板，如下所示：

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);
    }
}

}