Как получить все входные данные изasticseach с помощью Apache Camel?

Question

Давайте предположим, что у меня есть экземплярasticsearch, подобный этому:

from("direct:index")
    .to("elasticsearch://local?operation=INDEX&indexName=twitter&<br>
   indexType=tweet"); 

, и я добавил 10 твитов, как я могу получить весь список этих твитов отasticsearch?Я пробовал что-то вроде этого:

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

но это не работает, вы можете помочь мне сделать это?И какой тип данных будет в процессоре?

Мне нужно получить список всех твитов, использующих Apache Camel DSL, можете ли вы помочь мне сделать это?

Answer 1

Просто догадываюсь, но на странице Camel Elastic написано, что MULTIGET

Извлекает указанный тип индексов, указанный в MultigetRequest, и возвращает объект MultigetResponse в теле

Так что, я думаю, вам нужно предоставить MultigetRequest объект в теле сообщения и затем выполнить поиск в Elastic.

Это означало бы, что вы не можете использовать его напрямую как Потребитель с from(...), но вам придется вызвать его с .to(...) и убедиться, что сообщение содержит правильное тело.