Trung tâm cá nhân
sách gpt4 ai đã đi

apache-camel - Camel - 当消费目录不存在时停止路由

In lại 作者：行者123 更新时间：2023-12-04 05:06:08 32 4
mua khóa gpt4 Nike

我有一个 SFTP 路由(在 Spring XML 中)，它的 from 路径以每日更改的目录(即/yyyyMMdd)结尾，并且在 autoCreate=true 时一切正常或者路径开始时目录存在。但是如果目录不存在，我不允许创建目录!

当目录存在时，路由获取文件并自行终止。

当目录不存在时，路由会永久轮询并发出警告(即 org.apache.camel.component.file.GenericFileOperationFailedException: Cannot change directory to: 20160917 )并且永不停止。

如何避免这种行为(例如，将警告转换为空消息或异常或...)？我已经对startingDirectoryMustExist、consumer.bridgeErrorHandler 和许多其他人进行了实验，但没有任何成功。

简化路线(开始前，用实际日期填写 elmu.sftp.importDir 属性):

    <>
        uri="sftp://{{elmu.sftp.host}}:{{elmu.sftp.port}}{{elmu.sftp.importDir}}?username={{elmu.sftp.userName}}&password={{elmu.sftp.password}}&
        autoCreate=false&preferredAuthentications=password&binary=true&include={{elmu.importMask}}&initialDelay=100&
        noop=true&sortBy=file:name&sendEmptyMessageWhenIdle=true"/>
    
        
            ${body} != null
            ... a lot of stuff ...

Và directoryMustExist=true and startingDirectoryMustExist=true结果是一个带有此警告的无限循环(轮询): 
08:30:14,658 WARN SftpConsumer - Consumer Consumer[sftp://xxx.xxx.xx:22/DBHtest/ELMUteszt/Kiadott_adatok/20160918?autoCreate=false&binary=true&directoryMustExist=true&include=%5E.*%24&initialDelay=100&noop=true&password=xxxxxx&preferredAuthentications=password&sendEmptyMessageWhenIdle=true&sortBy=file%3Aname&startingDirectoryMustExist=true&username=xxx] failed polling endpoint: Endpoint[sftp://xxx:22/DBHtest/ELMUteszt/Kiadott_adatok/20160918?autoCreate=false&binary=true&directoryMustExist=true&include=%5E.*%24&initialDelay=100&noop=true&password=xxxxxx&preferredAuthentications=password&sendEmptyMessageWhenIdle=true&sortBy=file%3Aname&startingDirectoryMustExist=true&username=xxx]. Will try again at next poll. Caused by: [org.apache.camel.component.file.GenericFileOperationFailedException - Cannot change directory to: 20160918] 
org.apache.camel.component.file.GenericFileOperationFailedException: Cannot change directory to: 20160918
    at org.apache.camel.component.file.remote.SftpOperations.doChangeDirectory(SftpOperations.java:576)
    at org.apache.camel.component.file.remote.SftpOperations.changeCurrentDirectory(SftpOperations.java:564)
    at org.apache.camel.component.file.remote.SftpConsumer.doPollDirectory(SftpConsumer.java:107)
    at org.apache.camel.component.file.remote.SftpConsumer.pollDirectory(SftpConsumer.java:79)
    at org.apache.camel.component.file.GenericFileConsumer.poll(GenericFileConsumer.java:131)
    at org.apache.camel.impl.ScheduledPollConsumer.doRun(ScheduledPollConsumer.java:175)
    at org.apache.camel.impl.ScheduledPollConsumer.run(ScheduledPollConsumer.java:102)
    at java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
    at java.util.concurrent.FutureTask.runAndReset(Unknown Source)
    at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(Unknown Source)
    at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(Unknown Source)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
    at java.lang.Thread.run(Unknown Source)
Caused by: 2: No such file
    at com.jcraft.jsch.ChannelSftp.throwStatusError(ChannelSftp.java:2846)
    at com.jcraft.jsch.ChannelSftp._realpath(ChannelSftp.java:2340)
    at com.jcraft.jsch.ChannelSftp.cd(ChannelSftp.java:342)
    at org.apache.camel.component.file.remote.SftpOperations.doChangeDirectory(SftpOperations.java:574)
    ... 13 more

它不适用于 stepwise=false : 
11:52:19,210 WARN SftpConsumer - Consumer Consumer[sftp://xxx:22/DBHtest/ELMUteszt/Kiadott_adatok/20160918?autoCreate=false&binary=true&directoryMustExist=true&include=%5E.*%24&initialDelay=100&noop=true&password=xxxxxx&preferredAuthentications=password&sendEmptyMessageWhenIdle=true&sortBy=file%3Aname&startingDirectoryMustExist=true&stepwise=false&username=xxx] failed polling endpoint: Endpoint[sftp://xxx:22/DBHtest/ELMUteszt/Kiadott_adatok/20160918?autoCreate=false&binary=true&directoryMustExist=true&include=%5E.*%24&initialDelay=100&noop=true&password=xxxxxx&preferredAuthentications=password&sendEmptyMessageWhenIdle=true&sortBy=file%3Aname&startingDirectoryMustExist=true&stepwise=false&username=xxx]. Will try again at next poll. Caused by: [org.apache.camel.component.file.GenericFileOperationFailedException - Cannot list directory: DBHtest/ELMUteszt/Kiadott_adatok/20160918] 
org.apache.camel.component.file.GenericFileOperationFailedException: Cannot list directory: DBHtest/ELMUteszt/Kiadott_adatok/20160918

更新(根据@ruffp 的回答):

我试图设置一个自定义的 PollingConsumerPollStrategy，但我无法阻止它的路由。只有第三(注释行)停止路线，但我有几条路线，我不知道实际路线的名称。我怎么才能得到它？ 
    @Ghi đè
    public boolean rollback(Consumer consumer, Endpoint endpoint, int retryCounter, Exception cause) throws Exception {
        consumer.getEndpoint().stop(); // 1
        consumer.stop(); // 2
        consumer.getEndpoint().getCamelContext().stopRoute(route???); // 3
        trả về false;
    }

1 Câu trả lời

最后我用 consumer.exceptionHandler 解决了它.但似乎，此选项不在可用选项列表中 ( http://camel.apache.org/file2.html 我一直在反复阅读)刚刚在大页面底部举了一个例子。不幸的是，它是如此“隐藏”，以至于我到现在都没有看到它。

我设置了一个新类并实现了 handleExceptions 方法:

public class DirNotExistsExHandler implements ExceptionHandler

获得异常并决定做什么。在上下文中，我做了一个 bean 定义:


在消费者中，将 bean 传递给处理程序: 
consumer.exceptionHandler=#dirNotExistsExHandler

非常感谢您的帮助!

关于apache-camel - Camel - 当消费目录不存在时停止路由，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/39549318/

32 4 0
Bài viết được đề xuất: data-binding - Xamarin 将双向数据绑定(bind)到 RealmObject 引发错误
Bài viết được đề xuất: Smooks 调解器的 WSO2 ESB 自定义属性
Bài viết được đề xuất: .net - LINQ 是否在幕后迭代？
Bài viết được đề xuất: nginx - 301重定向时nginx保留端口号
行者123
Hồ sơ cá nhân

Tôi là một lập trình viên xuất sắc, rất giỏi!

Nhận phiếu giảm giá Didi Taxi miễn phí
Mã giảm giá Didi Taxi
Các bài viết nóng hổi trên toàn bộ trang web
Giấy chứng nhận ICP Bắc Kinh số 000000
Hợp tác quảng cáo: 1813099741@qq.com 6ren.com