2015-11-18 3 views
0

Пример с GroupedExchangeAggregationStrategy() работал отлично со мной. Но теперь задача состоит в том, чтобы передать значение параметра uri. ниже приведен код.Apache Camel Pass Параметр для многоуровневых uri с рестлетом

from("restlet:http://localhost:8089/createCustomer/{foo}")  
.enrich("direct:serviceFacade") 
.process(new Processor() {...}) 
.end(); 

from("direct:serviceFacade") 
.multicast(new GroupedExchangeAggregationStrategy()).parallelProcessing() 
    .enrich("restlet:http://localhost:8080/CamelRest/rest/restService/addressInfo/${header.foo}").enrich("restlet:http://localhost:8080/CamelRest/rest/restService/accountInfo/${header.foo}") 
.end(); 

Я получаю сообщение об ошибке:

Заголовок с ключом: header.foo не найден в Exchange. Обмен [Сообщение: [Тело пуста]]

ответ

0

Наконец-то я понял.

from("direct:serviceFacade") 
    .multicast(new GroupedExchangeAggregationStrategy()).parallelProcessing()  
    // .bean(RecipientListBean.class, "route")  
    .enrich("restlet:http://localhost:8080/CamelRest/rest/restService/addressInfo/{foo}") 
    .enrich("restlet:http://localhost:8080/CamelRest/rest/restService/accountInfo/{foo}") 
     .end(); 

Это будет делать магию ..

 Смежные вопросы

  • Нет связанных вопросов^_^