Output stream what writes to a FTP file via Camel.

camel_ftp_output_stream.groovy

class ExampleCamelFtpStream {


    static void main(String[] args) {
        new ExampleCamelFtpStream().run()
    }

    void run() {

        try {

            CamelContext camelContext = new DefaultCamelContext();

            Map options = [
                    //username: 'test',
                    //password: 'test777',
                    fileName: 'OUT.txt'
            ]


            OutputStream os = getFtpOutputStream("file:///tmp", options, camelContext)

            (1..100).each {
                println "line ${it}"
                os << "This is line number ${it}\n"
                sleep 50
            }

            os.close()

        } catch (Exception e) {
            println "EXCEPTION ${e}"
            e.printStackTrace()
        }

    }

    OutputStream getFtpOutputStream(String baseUrl, Map config, CamelContext camelContext) {

        String url = buildUrl(baseUrl, config)

        println "URL ${url}"

        ProducerTemplate producer = camelContext.createProducerTemplate()
        producer.start()

        PipedOutputStream pos = new PipedOutputStream()
        PipedInputStream pis = new PipedInputStream(pos)

        Future<Object> future = producer.asyncSendBody(url, pis)

        pos

    }


    String buildUrl(String baseUrl, Map config) {
        String optionString = config.findAll {k, v -> v != null}.collect { k, v -> "${k}=${v}" }.join('&')

        "${baseUrl}?${optionString}"
    }

}