Apache Camel File Component

The Apache Camel File component is a powerful tool for reading, writing, and manipulating files. It provides a simple and intuitive way to work with files and directories, making it easy to integrate file-based systems into your overall integration solution.

Consuming Files with the File Component

The File component can be used to read files from a directory and process them. To do this, you need to specify the directory from which you want to read the files and the pattern that you want to use to filter the files. For example, the following code reads all files from a directory and validates them. See Line 24 ff. to see a file consumer in action

See projekt here

Example

Java

package org.codenest.camel.route;

import org.apache.camel.builder.RouteBuilder;
import org.codenest.camel.processor.ContentValidator;
import org.springframework.stereotype.Component;

import static org.apache.camel.builder.endpoint.StaticEndpointBuilders.file;
import static org.apache.camel.builder.endpoint.StaticEndpointBuilders.timer;

@Component
public class CamelRoute extends RouteBuilder {
    @Override
    public void configure() throws Exception {
        // this route will just periodically create a new file
        from(timer("mytimer").period(10000))
                .log("test")
                .setBody(constant("setAnythingToBody"))
                // uncomment this to trigger a validation error
                //.setBody(constant("invalid"))
                .to(file("outputPath").fileName("thisWasGenerated.txt"))
                ;

        // here the file will be consumed
        from(file("outputPath"))
                .log("consumed")
                .process(new ContentValidator());
    }
}

And in the following you see the ContentValidator class

Java

package org.codenest.camel.processor;

import org.apache.camel.Exchange;
import org.apache.camel.Processor;
import org.springframework.stereotype.Component;

@Component
public class ContentValidator implements Processor {


    @Override
    public void process(Exchange exchange) throws Exception {
        String body = exchange.getIn().getBody(String.class);

        if (body.contains("invalid")) {
            throw new IllegalStateException("I should not be invalid");
        }
    }
}

Advanced

You can add many more properties to the file component. One common property is „noop“, which indicates that the file after being processed is not moved from the directory (great for testing). Another one is for example „move“, which decides where to move the file when the processing of the message was successful. If it was not successful, you can also send it to another directory with the option „.moveFailed“

Apache Camel File Component

Consuming Files with the File Component

Example

Advanced

1 Kommentar zu „Apache Camel File Component“

Kommentar verfassen Kommentieren abbrechen

Consuming Files with the File Component

Example

Advanced

Related Articles

1 Kommentar zu „Apache Camel File Component“

Kommentar verfassen Kommentieren abbrechen