Apache camel文件组件不移动文件

Question

public class MoveFilesTest {
    private static final Log LOG = LogFactory.getLog(MoveFilesTest.class);

    public static void main(String args[]) throws Exception {
        LOG.debug("create CamelContext");
        CamelContext context = new DefaultCamelContext();

        // add our route to the CamelContext
        context.addRoutes(new RouteBuilder() {
            File file = null;
            public void configure() {
                from("file:data/inbox?delay=100&noop=true")
                .process( new Processor() {

                    public void process(Exchange msg) throws Exception {
                        File file = msg.getIn().getBody(File.class);
                        LOG.debug("Processing file: " + file.getName());

                    }
                })

                .to("file:data/outbox").end();
            }
        });

        LOG.debug("start the route and let it do its work");
        context.start();

        context.stop();

    }
}

DEBUG [main] (MoveFilesTest.java:24) - create CamelContext
DEBUG [main] (MoveFilesTest.java:45) - start the route and let it do its work
 INFO [main] (DefaultCamelContext.java:1498) - Apache Camel 2.12.1 (CamelContext: camel-1) is starting
 INFO [main] (ManagedManagementStrategy.java:187) - JMX is enabled
 INFO [main] (DefaultTypeConverter.java:50) - Loaded 176 type converters
 INFO [main] (DefaultCamelContext.java:1689) - StreamCaching is not in use. If using streams then its recommended to enable stream caching. See more details at http://camel.apache.org/stream-caching.html
 INFO [main] (FileEndpoint.java:83) - Endpoint is configured with noop=true so forcing endpoint to be idempotent as well
 INFO [main] (FileEndpoint.java:89) - Using default memory based idempotent repository with cache max size: 1000
 INFO [main] (DefaultCamelContext.java:2183) - Route: route1 started and consuming from: Endpoint[file://data/inbox?delay=100&noop=true]
 INFO [main] (DefaultCamelContext.java:1533) - Total 1 routes, of which 1 is started.
 INFO [main] (DefaultCamelContext.java:1534) - Apache Camel 2.12.1 (CamelContext: camel-1) started in 8.936 seconds
 INFO [main] (DefaultCamelContext.java:1706) - Apache Camel 2.12.1 (CamelContext: camel-1) is shutting down
 INFO [main] (DefaultShutdownStrategy.java:172) - Starting to graceful shutdown 1 routes (timeout 300 seconds)
 INFO [Camel (camel-1) thread #2 - ShutdownTask] (DefaultShutdownStrategy.java:600) - Route: route1 shutdown complete, was consuming from: Endpoint[file://data/inbox?delay=100&noop=true]
 INFO [main] (DefaultShutdownStrategy.java:217) - Graceful shutdown of 1 routes completed in 0 seconds
 INFO [main] (DefaultCamelContext.java:1780) - Apache Camel 2.12.1 (CamelContext: camel-1) uptime 8.953 seconds
 INFO [main] (DefaultCamelContext.java:1781) - Apache Camel 2.12.1 (CamelContext: camel-1) is shutdown in 0.013 seconds

Answer 1

是的，你启动骆驼并立即停止。所以，当你把一个文件放到文件夹里。它不会处理，因为骆驼已经停止了。

Camel包含main实现，以保持Camel在独立应用程序中运行。

有链接：http://camel.apache.org/running-camel-standalone-and-have-it-keep-running.html