Kamel Enrich und AggregationStrategy

Question

Ich versuche, Kamel enrich EIP zu verwenden mit benutzerdefinierten AggregationStrategy d.h

from("direct:xyz") 
    .setHeader("...","") 
    .enrich("http://localhost:myservice", new AggregationStrategy() { 

     public Exchange aggregate(Exchange oldExchange, Exchange newExchange) { 
     ..... 
     } 
}); 

Ausgabe von HTTP-Endpunkt gibt XML-Antwort. Ich möchte, dass das gemarshallt und auf den Körper der newExchange gesetzt wird.

Derzeit ist dieses Ich mache von JaxbDataFormat zum AggregationStrategy Injektion und unmarshall Methode aufrufen .. d.h

public Exchange aggregate(Exchange oldExchange, Exchange newExchange) { 
    AnotherObj obj = dataFormat.unmarshall(newExchange, 
      newExchange.getIn().getBody(InputStream.class)); 

    Parentobj test = oldExchange.getIn().getBody(ParentObj.class) 

    test.setobj(obj) 
    oldExchange.getIn().setBody(test); 
    return oldExchange; 
    } 

Gibt es einen besseren Weg, dies zu erreichen?

Answer 1

Eine bessere (prägnante) Art und Weise einfach sein kann, dich die Abstellungsmethode in der Route rufen und im Datenformat übergeben:

Java DSL:

DataFormat jaxb = new JaxbDataFormat("com.acme.model"); 

from("activemq:My.Queue"). 
    unmarshal(jaxb). 
    to("mqseries:Another.Queue"); 

Frühling XML:

<camelContext id="camel" xmlns="http://camel.apache.org/schema/spring"> 
    <dataFormats> 
    <jaxb id="myJaxb" prettyPrint="true" contextPath="org.apache.camel.example"/> 
    </dataFormats> 

    <route> 
    <from uri="direct:marshalled"/> 
    <unmarshal ref="myJaxb"/> 
    <to uri="mock:result"/> 
    </route> 

</camelContext> 

http://camel.apache.org/data-format.html

Sie würden dies tun direkt nach de Rich/Aggregation

Answer 2

Verwenden Sie einfach "direct: route" auf der URI und tun, was Sie brauchen, mit dem neuen Austausch auf dieser Route (Anruf Service, Header setzen, unmarshall Daten), der resultierende Austausch wird als der neue erhalten Austausch in der Aggregationsstrategie.