Перехватив Обмен в Camel

Question

Предположим, у меня есть маршрут следующим образом

from("direct:A") 
    .process(new ProcessA()) 
    .setHeader(Exchange.HTTP_METHOD, "get") 
    .recipientList(simple(httpUri + header("doc_id")), "false") 
    .process(new ProcessB()) 
    .to("direct:B"); 

В приведенном выше пути httpUri = "http4: // локальный: 25600". Теперь я пытаюсь перехватить сообщение следующим образом.

context.getRouteDefinitions().get(0).adviceWith(context, new AdviceWithRouteBuilder() { 
    @Override 
    public void configure() throws Exception { 
     interceptSendToEndpoint("http4*") 
     .skipSendToOriginalEndpoint() 
     .process(new Processor() { 
      @Override 
      public void process(Exchange exchange) throws Exception { 
       //TODO         
      } 
     }); 
    } 
}); 

Проблема здесь заключается в том, что обмен не перехватываются и контекст на самом деле пытается сделать связь с httpUri хозяин даже есть skipSendToOriginalEndpoint.

Пожалуйста, дайте мне знать, если что-то не так в коде. Заранее спасибо.

Answer 1

Используется динамический маршрут, что означает, что конечная точка не известна во время определения. В результате вы не сможете перехватить на основе конечной точки http.

Вместо этого я бы заменил весь список получателей, а не только адрес назначения, называемый получателем.

Как простой способ сделать это с помощью weaveByType. Для того, чтобы сплести в процессоре, это будет выглядеть так:

weaveByType(RecipientListDefinition.class).replace().process(...) 

Как всегда с adviceWith, убедитесь, что для реализации isUseAdviceWith вернуться true, и затем вызвать context.start() после advicing в routeDefinition.