问题标签 [spring-camel]

我有以下代码：

简而言之，这段代码从中获取文件sftpConfiguration.getSourcePath()，对其进行分析，然后将其发送到sftpConfiguration.getDestPathRejected() 在我的本地机器上，它始终运行良好，但在测试环境中，我们的 QA 注意到了有趣的行为：有时文件会丢失一些数据。例如输入文件 - 20 MB，但在分析应用程序后放置文件的大小小于 20MB。例如，它可以是 6 MB。此外，如果对相同的文件大小重复此操作会发生变化。它可以变成 8 MB 等等。因此行为是不可预测的。

我认为资源处理有问题，但我不知道有什么问题。

有任何想法吗？

我有以下路线：

如您所见，我使用throwExceptionOnFailure=false

我从配置中获取我的网址。但我们发现如果

pushProperties.getUrl()=localhost:8080/url?action=myaction

并且在以下情况下不起作用

pushProperties.getUrl()=localhost:8080/url

骆驼中是否有通用方法将请求参数添加到 URL？

就像是：

骆驼api里面

一旦我的路线完成处理骆驼中的目录及其子目录，如何获得触发器？有什么办法可以在路线中指定吗？

我有 dsl 路线：

我想限制文件大小以供使用。例如，我想忽略大小超过 100Mb 的文件。如果骆驼遇到的文件超过100mb，我可以选择进行回调

我读过了：

http://camel.apache.org/ftp2.html

但我找不到任何相关的东西

我想filterFile在我的骆驼路线内使用。

我有这样的路线：

我已阅读file2 文档

这里写着：

但我不明白我应该在哪里使用这种简单的语言。

但是logger.warn("Error"); 没有被调用。

我错了什么？

如何为骆驼路线注册全局异常处理程序？

我有 spring boot 应用程序，spring boot 版本为 1.5.8camel 2.20.1

简单路线：

和简单的测试：

当我运行这个测试时，它运行良好，我收到一条消息并且端点很满意。如果我添加@SpringBootTest注释，测试失败？为什么 ？当我运行 maven clean install 时也没有注释它也会失败:(

任何人都知道这个注释对骆驼测试有什么作用，或者我该如何调整它以使其工作？

谢谢

我必须从我的 spring boot 应用程序中调用几个 rest web 服务。我打算使用 Camel 来配置流程和其他 EIP 用例。一些端点正在使用 oAuth2 身份验证。我打算使用 Spring oAuthResttempalte。互联网上的所有示例都使用restlet、CXF 或camel-http。

骆驼休息消费者

我无法找到仅使用 spring resttemplate 的单个示例。有没有人使用 Spring Resttemplate 实现 Camel Rest 消费者？

互联网上的一些示例使用码头服务器来使用休息端点。为什么你需要一个简单的休息消费者的码头服务器？

设置正文之后传递的正文为空。这是 SOAP 请求的路由。如何在骆驼路线本身中与所需的类对象进行交换？

我有一个 Camel 路由，它使用队列中的消息并将消息存储到数据库中。现在我想以优雅的方式手动关闭正在运行的骆驼路线。每当我需要停止 Camel 路线时，我都会触发一个 RestEndpoint。这个端点应该停止路由。但是，如果在关闭期间有任何正在运行的消息或事务正在运行，则它必须成功完成而不消耗来自骆驼路由的 from("") 端点的任何新消息，并在完成飞行消息或事务后关闭。谁能帮助我如何编码？