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

How to get Camel FTP to fetch only once on demand(如何让 Camel FTP 仅按需获取一次)

问题描述

我对 Camel 还很陌生.

I'm fairly new to Camel.

我一直试图让 Camel 根据需要仅通过 FTP 获取单个文件.我无法让它工作.这是我尝试过的.让我知道什么是最好的方法以及我的代码有什么问题.

I've been trying to get Camel to fetch a single file via FTP only once, on demand. I couldn't get it to work. Here is what I've tried. Let me know what is the best approach and what is wrong with my code.

1-读取文件后发送空消息，当收到空消息时，停止路由.

1- Send an empty message after the file was read and when the empty message is received, stop the route.

 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

And my 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
            public void run() {
                try {
                    exchange.getContext().stopRoute(routeId);
                } catch (Exception e) {
                }
            }
        };
    }
    stopper.start();
}

我第一次调用 producerTemplate.sendBody("direct:myStart", null); 时它实际上工作正常；

但我第二次调用 producerTemplate.sendBody("direct:myStart", null); 我得到了这个:

But the second time I call producerTemplate.sendBody("direct:myStart", null); I get this:

org.apache.camel.component.direct.DirectConsumerNotAvailableException: No consumers available on endpoint: Endpoint[direct://myStart]. Exchange[Message: [Body is null]]

我想我想要做的不是完全停止我的路......所以我尝试了另一种方式......

I guess what I want to do is not to stop my road completely... so I tried another way...

2- 实施 PollingConsumerPollStrategy

public class FtpPollStrategy implements PollingConsumerPollStrategy {

@Override
public boolean begin(Consumer consumer, Endpoint endpoint) {
    return true;
}

@Override
public void commit(Consumer consumer, Endpoint endpoint, int polledMessages) {
    try {
        consumer.stop();
    }
    catch (Exception e) {
        e.printStackTrace();
    }
}

@Override
public boolean rollback(Consumer consumer, Endpoint endpoint, int retryCounter, Exception cause) throws Exception {
    return false;
}

}

在我的路线上:

from("ftp:....disconnect=true&pollStrategy=#ftpPollStrategy")

我得到的是

java.lang.IllegalArgumentException: Could not find a suitable setter for property: pollStrategy as there isn't a setter method with same type: java.lang.String nor type conversion possible: No type converter available to convert from type: java.lang.String to the required type: org.apache.camel.spi.PollingConsumerPollStrategy with value #ftpPollStrategy

3 - 如果我不停止任何操作(如下面的评论中所建议)，找不到文件时，路由似乎永远不会停止轮询我的 FTP.我只给我的路线打了一次电话:

3 - If I don't stop anything (as suggested in the comments below) it looks like the route never stops polling my FTP when no file is found. I called my route only once :

producerTemplate.sendBody("direct:myStart", null);

还有路线

 from("direct:myStart")
.routeId("routeA")
.pollEnrich("ftp:...disconnect=true&sendEmptyMessageWhenIdle=true")
.to("validator:file.xsd")
.to("somewhere")
.end();

查看日志:

2015-08-05 08:55:28,942 调试 [correlation-ids:faad163b-f68e-4e91-b5fd-e5e2f86d42bd,user:] [(camelContext)-1] (org.apache.camel.component.file.remote.RemoteFileConsumer:152) TelechargementMetadonneesRouteBuilder- 未连接/登录，连接到:ftp://pierre@localhost:212015-08-05 08:55:28,943 信息 [相关 ID:faad163b-f68e-4e91-b5fd-e5e2f86d42bd，用户:] [(camelContext)-1] (org.apache.camel.component.file.remote.RemoteFileConsumer:156) TelechargementMetadonneesRouteBuilder- 连接并登录到:ftp://pierre@localhost:212015-08-05 08:55:28,945 调试 [相关 ID:faad163b-f68e-4e91-b5fd-e5e2f86d42bd，用户:] [(camelContext)-1] (org.apache.camel.component.file.GenericFileConsumer:130) TelechargementMetadonneesRouteBuilder- 轮询耗时 0.002 秒:2015-08-05 08:55:28,945 调试 [相关 ID:faad163b-f68e-4e91-b5fd-e5e2f86d42bd，用户:] [(camelContext)-1] (org.apache.camel.component.file.remote.RemoteFileConsumer:121) TelechargementMetadonneesRouteBuilder- 断开连接:ftp://pierre@localhost:212015-08-05 08:55:29,446 调试 [相关 ID:faad163b-f68e-4e91-b5fd-e5e2f86d42bd，用户:] [(camelContext)-1] (org.apache.camel.component.file.remote.RemoteFileConsumer:152) TelechargementMetadonneesRouteBuilder-未连接/登录，连接到:ftp://pierre@localhost:212015-08-05 08:55:29,447 信息 [相关 ID:faad163b-f68e-4e91-b5fd-e5e2f86d42bd，用户:] [(camelContext)-1] (org.apache.camel.component.file.remote.RemoteFileConsumer:156) TelechargementMetadonneesRouteBuilder- 连接并登录到:ftp://pierre@localhost:212015-08-05 08:55:29,449 调试 [相关 ID:faad163b-f68e-4e91-b5fd-e5e2f86d42bd，用户:] [(camelContext)-1] (org.apache.camel.component.file.GenericFileConsumer:130) TelechargementMetadonneesRouteBuilder- 轮询耗时 0.002 秒:2015-08-05 08:55:29,449 调试 [相关 ID:faad163b-f68e-4e91-b5fd-e5e2f86d42bd，用户:] [(camelContext)-1] (org.apache.camel.component.file.remote.RemoteFileConsumer:121) TelechargementMetadonneesRouteBuilder- 断开连接:ftp://pierre@localhost:21

任何帮助将不胜感激.

推荐答案

所以我找到的解决方案是使用场景#1，但是停止并重新启动路由.

So the solution I found is using the scenario #1, but stop and restart the route.

exchange.getContext().stopRoute(routeId);
exchange.getContext().startRoute(routeId);

这篇关于如何让 Camel FTP 仅按需获取一次的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持编程学习网！