Legendes Apache Camel Dynamisches Routing

Question

Ich habe einen einfachen dynamischen Router einrichten:

public String slip(String body, @Header(Exchange.SLIP_ENDPOINT) String previous) { 
       if (previous == null) { 
        return "mock:a"; 
       } 
        else if (body.contains("status=2")) { 
        return "mock:b"; 
       } 
        else if (body.contains("status=3")) { 
        return "mock:c"; 
       } 

       // no more so return null 
       return null; 
      } 

Mock a, b, c sind Routen mit kundenspezifischen Prozessoren.

public void process(Exchange exchange) throws Exception { 
     String str_request = ""; 
     String str_requestNew = ""; 

     str_request = (String) exchange.getIn().getBody(); 

     if(str_request.contains("status=1")) 
      str_requestNew = "status=2"; 
    } 

1. Wie ich den Nachrichtentext zwischen Strecken in meinem benutzerdefinierten Prozessor über Java DSL aktualisiere. exchange.getOut(). SetBody (newreq); ?

2. Muss ich einen neuen Producer erstellen und die Nachricht zurück an den dynamischen Router senden? ProducerTemplate-Vorlage = exchange.getContext(). CreateProducerTemplate(); template.sendBody (myDynamicRouterEndpoint, newreq); oder wird mein Router den neuen Körper abholen, wenn Sie über das Verfahren 1.

Oder gibt es einen großen Fehler alle zusammen in meiner Logik? :)

Answer 1

Sie können es tun, wie Sie in 1.

beschreiben Noch einfacher ist es, wenn Sie die Bean-Komponente verwenden. Dann können Sie eine einfache Java-Methode haben zum Lesen und Einstellen des Körpers:

public String doSomething (String Körper) { }

Diese den Körper in dem Parameter erhalten wird und der Rückgabewert wird der neue Körper . Dies macht Ihre Bohne auch unabhängig von Camel.