Tag: camel ftp

如何让Camel FTP只按需获取一次

我对Camel很新。 我一直试图让Camel按需只通过FTP获取一个文件。 我无法让它发挥作用。 这是我尝试过的。 让我知道什么是最好的方法和我的代码有什么问题。 1-在读取文件后发送空消息 ，当收到空消息时，停止路由。 from(“direct:myStart”) .routeId(“routeA”) .pollEnrich(“ftp:…disconnect=true&sendEmptyMessageWhenIdle=true”) .choice() .when(body().isNull()).process(RouteStopper(“routeA”)) .otherwise().to(“validator:file.xsd”) .to(“somewhere”) .end(); 还有我的RouteStopper public class RouteStopper implements Processor { private String routeId; private Thread stopper; public RouteStopper(String routeId) { this.routeId = routeId; } @Override public void process(Exchange exchange) throws Exception { if (stopper == null) { stopper = new Thread() { @Override […]