Apache camel demo taking data from a TCP connection and writing it to outbox/stream.txt. Requires camel-core and camel-mina2

CamelDemo.java

import org.apache.camel.CamelContext;
import org.apache.camel.Exchange;
import org.apache.camel.Processor;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.impl.DefaultCamelContext;

public class CamelDemo {
    public static void main(String[] args) throws Exception {
        CamelContext cContext= new DefaultCamelContext();
        RouteBuilder builder= new RouteBuilder() {
            public void configure() {
                from("mina2:tcp://localhost:8080?textline=true&sync=false")
                    .setHeader(Exchange.FILE_NAME, constant("stream.txt"))
                    .process(new Processor() {
                        @Override
                        public void process(Exchange exchange) throws Exception {
                            String payload= exchange.getIn().getBody(String.class);
                            exchange.getIn().setBody(String.format("%s%n", payload));
                        }
                    })
                    .to("file:outbox?fileExist=Append");
            }
        };

        cContext.addRoutes(builder);
        cContext.start();

        try {
            Thread.sleep(60000);
        } catch(InterruptedException ex) {
        }
        cContext.stop();
    }
}