Apache Camel Resequence Programm funktioniert nicht

Question

Ich versuche, ein einfaches Re-Sequence-Programm mit Apache Camel auszuführen. Dieses Programm verwendet Java-DSL, um eingehende Java-Nachrichten neu zu sortieren. Wenn ich dieses Programm ausführe, werden die Nachrichten in den Ordner geschrieben, aber scheinen nicht in einer bestimmten Reihenfolge basierend auf dem Header-Wert oder der alphabetischen Reihenfolge des einzelnen Worts im Nachrichtentext zu sein. Die Dateien, die Camel erstellt, sind noch nicht in Ordnung, als ob die resequence DSL-Funktion nichts getan hätte.

Wie bekomme ich dieses Programm, um die Nachrichten tatsächlich zu bestellen, wie die Arrays.sort() Methode tun würde? Wie kann ich dieses Programm dazu bringen, die Nachrichten neu zu sortieren und dann in der korrekten Sortierreihenfolge zu einer einzigen Datei zusammenzufassen?

Hier ist das Programm ... Ich rufe die Haupt Camel Route über die andere Klasse, die die main Methode hat.

import org.apache.camel.builder.RouteBuilder; 

public class SortThoseMessages extends RouteBuilder { 

    @Override 
    public void configure() throws Exception { 

     from("direct:pointA") 
       .resequence(header("grocery")) 

       .to("file:target/pointB"); 
    } 

} 

Die Klasse unten hat main und erzeugt die Nachrichten in der Warteschlange, pointA.

import org.apache.camel.CamelContext; 
import org.apache.camel.impl.DefaultCamelContext; 
import org.apache.camel.ProducerTemplate; 

public class NewSequenceMain { 

    public static void main(String[] args) { 
     CamelContext c = new DefaultCamelContext(); 

     try { 

     c.addRoutes(new SortThoseMessages()); 



     ProducerTemplate template = c.createProducerTemplate(); 

     c.start(); 

     template.sendBodyAndHeader("direct:pointA", "apple", "grocery", 1); 
     template.sendBodyAndHeader("direct:pointA", "orange", "grocery", 3); 
     template.sendBodyAndHeader("direct:pointA", "bannanna", "grocery", 2); 

     Thread.sleep(5000); 
     c.stop(); 

     } catch(Exception ex) { 
      System.err.println("Exception thrown -> " + ex); 
      System.err.println("Now printing stacktrace..."); 
      ex.printStackTrace(); 
     } 

    } 

} 

Answer 1

Die Nachrichten können innerhalb der Camel-Route neu sequenziert werden, aber nicht, wenn sie in die Datei geschrieben werden. Um die Re-Sequenz zu sehen, rufen Sie das Java DSL aggregator auf, um die Nachrichtentexte in der angegebenen Reihenfolge zu sehen. Die Nachrichten im gebuchten Programm sind nach der Nummer der Kopfzeile geordnet. Der Methodenaufruf auf der Objektreferenz ProducerTemplate setzt den Header als Ganzzahl im letzten Argument des Methodenaufrufs sendBodyAndHeader().

Um die Resequenzierung wirksam in einer einzigen Datei als Ziel der Camel Route siehe unten das Beispiel Besuche:

import org.apache.camel.builder.RouteBuilder; 


public class ReorganizingMessages extends RouteBuilder { 

    @Override 
    public void configure() throws Exception { 

     from("direct:pointA") 
       .resequence(header("grocery")) 
       .to("log://org.apache.camel.howto?showAll=true&multiline=true") 

       .aggregate().constant(true).completionTimeout(100L). 
       aggregationStrategy(new StringAggregator()) 
       .to("file:target/pointB"); 
    } 

} 

Der obige Code verwendet eine benutzerdefinierte Aggregator Java Bean, die gesehen werden kann unten.

import org.apache.camel.Exchange; 
import org.apache.camel.processor.aggregate.AggregationStrategy; 

public class StringAggregator implements AggregationStrategy { 

    @Override 
    public Exchange aggregate(Exchange old, Exchange new1) { 
     if (old == null) { 
      return new1; 
     } 

     String oldBody = old.getIn().getBody(String.class); 
     String newBody = new1.getIn().getBody(String.class); 
     old.getIn().setBody(oldBody + " " + newBody); 
     return old; 

    } 

}