如何使用apache Camel从elasticseach获得所有条目？

Question

让我们假设我有如下的elasticsearch实例：

 from("direct:index")
    .to("elasticsearch://local?operation=INDEX&indexName=twitter&

   indexType=tweet"); 

from("elasticsearch://local?operation=MULTIGET&indexName=twitter&    indexType=tweet").process(new MyProcessor())
   .to("direct:somewhere")  

我需要使用apache camel DSL的所有推文列表，你能帮我做这件事吗？

Answer 1

只是猜测，但是骆驼弹性页面说multiget

检索MultigetRequest中指定的指定索引类型，并在正文中返回MultigetResponse对象

因此，我想您必须在消息正文中提供MultigetRequest对象，然后以弹性方式执行搜索。

这意味着您不能直接使用from(...)作为使用者，而必须使用.to(...)调用它，并确保消息包含正确的正文。