Apache Camel:使用peedicateBuilder并从wher()函数访问它们,复合条件
我正在尝试将条件与谓词构造器相复合,并将其保存到标题中,以从wher()函数访问谓词。一开始,我将身体设置为 Hello World 。身体也不是无效的 或者…
如何将参数从骆驼路线传递到命名的名称?
我在Spring-Boot上有一个运行骆驼的应用程序。 我想从骆驼路线中将被重试的参数重试。 名字Query: @NamedQuery(name = "findFailedMessages", query …
如何使用Java中的Apache Camel从目录中获取特定文件?
我有一个方案,一个目录包含各种名为pattern filehmm的文件,例如: hh = hhus mm =分钟 dir: file1200.txt file1210.txt File1220.txt 其他File1.tx…
Apache骆驼:使用()中使用复合条件
我正在使用Apache骆驼DSL路由,并且想检查身体是否不是 null ,并且主体不包含像身份验证失败的子字符串。在Java中类似: if(body != null && !body.c…
Apache Camel:MethodNotFoundException,由于以下原因未能在NULL上调用方法
我尝试遵循用于Apache Camel教育的视频教程,并尝试以下一个方式尝试聚合队列对象: @Component public class AggregationRoute extends RouteBuilder…
Apache骆驼错误:由于以下原因未能提取身体:
我尝试使用Apache Camel框架的下一个情况: 获取CSV文件 拆分数据,然后将其发送到队列中的排列 数据中,从队列 CSV文件中接收到数据: "id","from","…
由于骆驼上下文造成的错误,我无法运行程序,该如何解决这个问题?
因此,我在这里要做的是通过Camel Apache创建一个变焦会议。每当我运行程序时,我都会遇到错误,并且导致错误的行是启动骆驼上下文 c.start()时 这…
Apache Camel Transform json to Pojo
我正在尝试将简单的JSON文件转换为Apache Camel中的Pojo,但我无法正常工作。 Routes.java package org.acme.bindy.ftp; import org.apache.camel.Exc…
使用Dotry-Docatch在Apache Camel中动态调用Groovy脚本
我正在构建一条称为“ Groovy脚本”的路线,该脚本的路径是动态计算的,如果找不到该脚本,则默认为通用的静态脚本: .doTry() .toD("language://groo…
您可以收听SpringCamelContext状态吗?
使用EventNotifierSupport,我可以听CamelContextStartedEvent。但是,在所有其他路线已经初始化之后,我需要在上下文中添加一个根。目前,该事件发生…
使用Apache Camel上传到S3存储桶中,如何使用S3托管密钥启用服务器端加密?
我将Apache骆驼与AWS2-S3模块一起使用来访问S3存储桶。我正在使用Endpoint-DSL来编程路线。 我可以从存储桶中连接并阅读,但是在尝试上传时,我会被拒…
如何在Spring Boot应用程序中为Apache Camel路线创建拦截器
我有一个简单的路由定义,对于此路线,我想定义一个传出的拦截器,以便在任何完成的请求中,我会调用一个设置特定标头的富集器。 from("direct:remote…
无法创建Camel Salesforce端点
我正在尝试使用Apache Camel Salesforce组件连接到Salesforce。 这是我试图开始的一条非常简单的路由: @Override public void configure() throws Ex…