in load-balancer-eip/src/main/java/org/apache/camel/springboot/example/CustomLoadBalancer.java [25:38]
public boolean process(Exchange exchange, AsyncCallback callback) {
String body = exchange.getIn().getBody(String.class);
try {
if ("AE".contains(body)){
getProcessors().get(0).process(exchange);
} else if ("BCD".contains(body))
getProcessors().get(1).process(exchange);
}
catch (Exception e) {
exchange.setException(e);
}
callback.done(true);
return true;
}