Как мне использовать pollEnrich с Bean в Apache Camel?
Я пытался использовать это, но получаю исключение «В этом случае вы не можете использовать из конечной точки bean», я вызываю rest api, но клиент предоставил jarфайл, поэтому мне нужно позвонить боб и получить дополнительную информацию.
from("quartz2://tsTimer?cron=" + cron + "&trigger.timeZone=" + timezone)
.bean(tradingService)
.process(new Processor() {
@Override
public void process(Exchange exchange) throws Exception {
exchange.setProperty("fileName","input-" + dateFormat.format(new Date()) + ".xml");
}
})
.pollEnrich("bean:tradingService", new AggregationStrategy() {
@Override
public Exchange aggregate(Exchange oldExchange, Exchange newExchange) {
System.out.println("oldExchange : " + oldExchange +" newExchange : " + newExchange);
return null;
}
})
.marshal().jacksonxml(true)
.wireTap("file:" + auditDir + "/?fileName=${header.fileName}")
//split or merge
.to("xslt:trans.xslt")
.to(outQueue)
.to("log:org.ts.tradingservice.camel?level=INFO&showBody=true")
.end();