问题标签 [spring-camel]

我正在使用 camel-spring 编写一个基本的骆驼应用程序。我可以发送电子邮件，但我无法在其中发送正文和主题。我尝试了几种方法，但我在邮件正文中得到的唯一内容是文件内容。请如果您有任何想法，请提供您的意见。

我已经添加了我尝试过的所有组合，但它们不起作用提前谢谢。

我正在尝试从骆驼弹簧创建 csv 文件但出现错误。以下是我开发的代码-

我也尝试过使用<convertBodyTo type="java.util.List"/>，但它给了我例外

没有类型转换器可用于从类型：com.test.TestBean 转换为所需类型：java.util.List，值为 com.test.TestBean@26cd85e5[name=test,tumber=500,batchId=122,Type=XYZ, c_count=25,Count=14,金额=555]

这里TestBean 是我的POJO，我从bean:TestProcessor 返回TestBean 对象的java.util.list。骆驼会自动将对象的属性与标头链接，还是我需要编写单独的处理器类进行类型转换，如果是，那么如何将 java.util.list 转换为其中所需的格式？

提前致谢。

我正在尝试将 .txt 文件推送到现有的 .tar 文件中，但无法成功。是否可以通过骆驼。

我已经用 Camel 配置了 REST。我已经成功地从 writen API 获得响应。我的问题是，如果我在正确的 API 字符串之后添加任何内容，那么给定的 api 就可以工作。

骆驼路线

web.xml 中的配置

从 PostMan 我点击下面的 api 并获得显示的结果。

方法： POST | http://localhost:8080/camel-rest/rest/say/bye
输出： Bye(post) World

方法： POST | http://localhost:8080/camel-rest/rest/say/bye/anything
输出： Bye(post) World

方法： POST | http://localhost:8080/camel-rest/rest/say/by ?
输出： 错误：服务器没有找到与请求 URI 匹配的任何内容

>> 我的问题是为什么/say/bye/anything正在工作，即使我没有在路线中的任何地方列出。我在路线上有什么错误吗？

>> 为什么它与 'rest/say/bye' 匹配？

我正在使用 netty4 构建一个 HL7 侦听器并处理 HL7 消息。一旦成功处理，就会发回一个 ACK​​。

这在我的本地日食中运行良好。我发出一条 HL7 消息，然后我得到一个 Ack。

但是我将此应用程序打包到一个 jar 中并将其放在我的服务器上，然后尝试执行

我没有收到回复。我得到一个封闭的连接异常。

调试 NettyConsumer - 频道：[id: 0xdf13b06b, L:0.0.0.0/0.0.0.0:4444] 写作主体：MSH|^~\&|Karisma||Kestral|Kestral|20180309144109.827+1300||ACK^R01|701| |2.3.1 2018-03-09 14:41:09,838 [ad #3 - WireTap] 调试 WireTapProcessor - >>>>（窃听）direct:b Exchange[] 2018-03-09 14:41:09,839 [ServerTCPWorker]调试 NettyConsumer - 原因：[org.apache.camel.CamelExchangeException - 无法将响应写入 null。交易所[ID-annan06-56620-1520559639101-0-2]。原因：[java.nio.channels.ClosedChannelException - null]] org.apache.camel.CamelExchangeException：无法写入对 null 的响应。交易所[ID-annan06-56620-1520559639101-0-2]。引起：[java.nio.channels.ClosedChannelException - null] at org.apache.camel.component.netty4.handlers.ServerResponseFutureListener。

我想使用 Apache Camel 构建一个带超时的同步路由，但我在框架中找不到任何可以解决它的东西。所以我决定为我构建一个流程。

我这样称呼这个过程：

我想知道我的方式是否是推荐的方式，如果不是，建立超时同步路由的最佳方式是什么？

我使用 Camel DSL 路由定义：

当我将文件放入 sftp 文件夹时，我看到以下日志：

我想禁用主机验证。

看起来添加&useUserKnownHostsFile=false到路径可以解决我的错误。但是我有很多路由定义，我不喜欢给每个 URL 添加这个后缀。我可以全局禁用此验证吗？

如何使用自定义 bean 作为骆驼中的生产者端点，然后将其连接到处理 bean 或/和消费者 bean。

例如，我想使用其中一个 bean 方法来使用数据库中的数据，然后将结果传递给同一个 bean 的另一个方法或另一个 bean 来处理数据，然后传递给 jms 队列。

我想做类似以下的事情，但流程永远不会进入 patstat 服务

我使用 DSL 配置和 spring。

我的路线如下所示：

它允许我从中读取文件seda:rest_upload，然后将其移动到 sftp 文件夹。

我想再移动一个文件。我知道方法内部的路径和内容process。

我怎样才能实现它？

更新

我当前的代码；

有没有办法在camel + spring-ws中返回自定义主体（例如自定义bean）和http状态为500？

我试过了

然后在处理器公共类 ExceptionProcessor 中实现 Processor {

}

但即使身体是我想要的，http状态总是200。
你能帮帮我吗？

更多信息：我使用的是骆驼版本 2.20.2