Асинхронное изменение активатора обслуживания EIP?

Question

Мы имеем следующий маршрут верблюд в нашем приложении:

from(webServiceUri).routeId("webServiceRoute") 
     .unmarshal(jaxb) 
     .process(new Processor() { 
      @Override 
      public void process(Exchange exchange) throws Exception { 
       final Message in = exchange.getIn(); 
       final DataRequest body = in.getBody(DataRequest.class); 
       final DataRequest.Items items = body.getItems(); 
       itemValidator.validate(items.getItem()); 
       getContext().createProducerTemplate().sendBody(importUri, body); 
       DataResponse response = new DataResponse(); 
       response.setReturnCode(ReturnCode.SUCCESS); 
       in.setBody(response); 
      } 
     }) 
     .marshal(jaxb); 

Мы хотим «webServiceRoute», чтобы вернуть пользователю ответ, как только процессор проверены данные и переслал сообщение «importUri». Но сейчас кажется, что ответ не возвращается вызывающему абоненту до тех пор, пока обмен «importUri» не будет завершен. Итак, мой вопрос заключается в том, что такое «правильный» способ асинхронной пересылки полученного запроса в другую очередь? От «importUri» не будет никакого ответа (т. Е. Он должен быть InOnly).

Answer 1

Вы можете заменить .sendBody (importUri, body) на .asyncSendBody (importUri, body).

Тем не менее, я считаю, что ваш маршрут выглядит странно для меня, почему вы используете процессор для пересылки своего сообщения. Я бы написал что-то вроде:

DataResponse successResponse = new DataResponse(); 
response.setReturnCode(ReturnCode.SUCCESS); 

from(webServiceUri).routeId("webServiceRoute") 
    .unmarshal(jaxb) 
    .bean(WebServiceRouteHelper.class,"validate") 
    .to(importUri) 
    .setBody(constant(sucessResponse)) 
    .marshal(jaxb); 

class WebServiceRouteHelper { 
    public DataRequest validate(DataRequest dataRequest) throws Exception { 
     final DataRequest.Items items = body.getItems(); 
     itemValidator.validate(items.getItem()); 
     return dataRequest; 
    } 
}