我想通过REST调用使用骆驼的路线从FTP下载文件集: 我想以下几点: from("cxfrs:bean:restndpoint") .pollEnrich("some ftp url") .to("destinationFilesLocation") .bean(MyBean.class);
它仅适用于一个文件在ftp上,当我试图运行它再一次它只是等待文件。如果我用(“某些ftp url”替换pollEnrich(“某个ftp url”)机智),骆驼不会等待休息时间,随时调用下载文件。下载集从FTP与骆驼的文件通过REST调用
0
A
回答
0
这就是pollEnrich EIP模式的工作原理。它轮询单个消息。
您的用例通过REST调用下载一组FTP文件听起来更像是您应该使用Control Bus EIP模式,其中REST调用将触发启动另一个执行FTP下载的路由。
0
像这样的事情对我的作品:
from("cxfrs:bean:restndpoint")
.to("controlbus:route?action=start&routeId=ftpRouteId&async=true");
from("some ftp url").routeId("ftpRouteId").noAutoStartup()
.choice()
.when(body().isNull())
.to("direct:extract")
.otherwise()
.to("destinationFilesLocation");
from("direct:extract")
.to("controlbus:route?action=stop&routeId=ftpRouteId&async=true")
.bean(MyBean.class);
相关问题
- 1. 骆驼下载文件
- 2. 用骆驼与REST服务
- 3. Apache的骆驼下载文件http4
- 4. 骆驼FTP - 已知文件名的FTP使用者
- 5. Apache的骆驼 - 从文件
- 6. 使用php下载文件通过ftp
- 7. 通过Quartz调度程序通过FTP下载文件
- 8. 通过骆驼sql存储组件存储过程调用
- 9. 在Android上通过FTP下载文件
- 10. 通过FTP下载gunzipped文件
- 11. 骆驼是否适合使用更改的ftp文件?
- 12. 从ftp下载csv文件与ruby sinatra
- 13. 如何获取骆驼内容Enricher从REST调用处理Exchange?
- 14. 重复使用骆驼FTP路由
- 15. F#通过隐式SSL通过FTP下载文本文件
- 16. 我想读取FTP文件使用Apache骆驼
- 17. Apache的骆驼:SFTP:下载的文件多次
- 18. 从FTP下载xml文件
- 19. 如何通过ftp通过弹簧集成通过ftp身份验证来下载文件
- 20. 通过骆驼将文件复制到HDFS2不起作用
- 21. 如何使用.NET通过SSL通过SSL从FTP服务器下载文件?
- 22. Apache的骆驼FTP消费者加载相同的文件一次又一次
- 23. 如何通过NSURLSessionStreamTask从FTP下载?
- 24. 调试骆驼头
- 25. 从iPhone通过FTP协议上传/下载文件
- 26. 通过骆驼传递统一的webservices
- 27. 骆驼ErrorHandler不调用
- 28. 阿帕奇骆驼与ActiveMQ集群
- 29. 从属性文件读骆驼常量
- 30. 问题与骆驼
谢谢您的回答。这听起来正是我需要的。你能指点一下路线应该是什么样子的例子吗? –