Apache Camel-Datei-Splitter von Beispiel

Ich bin, da wird eine Datei mit numerischen IDs, getrennt durch Zeilenumbrüche ("\n"):

123948
939904
129384
234049

etc. Ich will Kamel zum umwandeln der Datei in eine Instanz der folgenden POJO:

public class IDFile {
    private String fileName;    //The name of the file
    private List<Long> ids;     //All the IDs in the file (123948, 939904, etc.)

    //Constructor, getters/setters, etc.
}

Ich versuche, um zu sehen, wenn ich Camel Splitter Komponente, dies zu tun für mich, aber es fühlt sich an wie ich bin versucht zu zwingen, einen Runden Pflock in ein quadratisches Loch:

<route>
    <from uri="file://input/idfile"/>
    <split streaming="true">
        <tokenize token="\n" />
        <to uri="bean://idfileProcessor?method=process"/>
    </split>
</route>

Oben sieht aus wie es aufgeteilt würde meine Datei in ein List<Long>, aber ich brauche den Namen der Datei im Zusammenhang mit der Liste als gut. Irgendwelche Ideen?

tut idfileProcessor Karten zu IDFile irgendwo. denn wie es aussieht seine einem Prozessor. wenn es ist, könnte Sie uns zeigen, wie Sie die Verarbeitung der Börse?
Danke @Ashish (+1) - ich denke, mein denken war, die <split> führen Sie die Transformation für mich, so dass durch die Zeit, die Botschaft zu idfileProcessor (ja, ein Kamel Processor), ich kann nur extrahieren Sie die IDFile POJO aus dem exchange-etwa so: IDFile idFile = (IDFile)exchange.getIn().getBody();. Die idfileProcessor dann könnte process die IDFile Instanz. Sorry für die Verwirrung!

InformationsquelleAutor IAmYourFaja | 2013-12-18

  1. 4

    Es ist ein header, der "CamelFileName" an der Börse. Ihr Prozessor/bean übergeben wird eine Referenz auf den Austausch und Sie können die header von es und verbinden es mit dem token, den Sie aufgerufen worden.

    Deine route könnte so Aussehen:

    <camel:route id="splitter_test">
    <camel:from uri="file:///home/steppra1/camel_test?delete=true&amp;idempotent=true" />
    <camel:to uri="bean:splitBean?method=init" />
    <camel:split streaming="true">
        <camel:tokenize token="\n" />
        <camel:to uri="bean:splitBean?method=addToken" />
    </camel:split>
    <camel:to uri="bean:splitBean?method=done" />
    <camel:log message="${in.body}" loggingLevel="INFO" logName="split_test" />
</camel:route>

    Den Bohnen, die Sie verwenden, um den Zustand zu verwalten, die auf dem exchange-Objekt:

    public class SplitBean {
    public Object init(Exchange exchange) {
        exchange.setProperty("splitTokens", new ArrayList<Integer>());
        return exchange.getIn().getBody();
    }

    public Object addToken(Exchange exchange) {
        ((List<Integer>)exchange.getProperty("splitTokens")).add(Integer.parseInt((String)exchange.getIn().getBody()));
        return null;
    }

    public Tuple done(Exchange exchange) {
        return new Tuple<String, List<Integer>>((String)exchange.getIn().getHeader("CamelFileName"), (List<Integer>)exchange.getProperty("splitTokens"));
    }
}

    Einer Datei, die die Zeilen enthält 

    1
2
3
5

    zugeführt, um die route unter den Namen splitter.text und splitter_2.txt ergibt sich die folgende log-Ausgabe:

    2013-12-18 18:20:02,081 INFO  split_test - Tuple [first=splitter.txt, second=[1, 2, 3, 5]]
2013-12-18 18:20:46,610 INFO  split_test - Tuple [first=splitter_2.txt, second=[1, 2, 3, 5]]

    HTH

    Danke @Ralf (+1) - inside my idfileProcessor (das ist nur eine Java-Klasse implementieren Camel Processor, und daher enthält ein public void process(Exchange) - Methode), können Sie ein Codebeispiel, wie ich in der Lage sein zu erhalten, meine IDFile Instanz, das heißt, ich müsste sowohl die String fileName Feld (irgendwie gewonnen aus der CamelFileName header, die Sie erwähnt) sowie die List<Long> ids? Nochmals vielen Dank!
    Ich habe aktualisiert die Antwort mit einem Beispiel über eine Bohne, nicht ein Prozessor. Sorry, ich habe nicht Lesen Sie Ihren Kommentar aufmerksam genug. In Ihrem Prozessor können Sie den Zugriff auf die Datei-Namen wie in ich in der done(Exchange) Methode. Ich habe auch das Gefühl, dass keine Java-bean sollte erforderlich sein, und dass Sie es tun konnte, mit einem der unterstützten script-Sprachen direkt in die Feder DSL. Vielleicht hat jemand anderes könnte ein Beispiel geben für, die?

    InformationsquelleAutor Ralf

Schreibe einen Kommentar