apache-camel相关内容

在 apache camel 中处理大型压缩文件

我正在尝试从 ftp 服务器获取具有 .zip 压缩的单个文件,并尝试使用骆驼使用 .gzip 压缩将其存储在 S3 中.以下是我目前的路线. from("sftp://username@host/file_path/?password=&noop=true&streamDownload=true").routeId("route_id").setExchangePatter ..
发布时间:2022-01-19 08:50:22 其他开发

如何将骆驼中的 BeanInvocation 对象转换为消息正文和标头?

我正在使用 Camel Proxy 公开一个接口作为起点一条路线.它使用 BeanInvocation 对象作为消息体.如何根据传递给接口的参数设置消息正文和标头? 公共接口测试{公共无效sayHi(字符串名字,字符串姓氏);} 我想制作身体 (firstName + " " + lastName).我还想知道如何将一个参数设置为消息的标头,将另一个参数设置为正文. 解决方案 它使用与 ..
发布时间:2022-01-19 08:48:26 Java开发

如何使用 Apache camel 使用 cxf 组件调用第三方 Web 服务

我浏览了 Apache camel 网站和 camel in action 上的示例,它们都非常关注公开 Web 服务.我在网上找到的唯一示例不起作用. 我正在尝试访问第三方网络服务 wsdl - http://www.webservicex.net/CurrencyConvertor.asmx?WSDL 此服务具有计算货币汇率的操作/方法.操作名称为“ConversionRate". ..
发布时间:2022-01-19 08:47:46 服务器开发

使用 Java 配置执行器 JMS 健康检查返回误报

我遇到了一个问题,即执行器探测对于 JMS 运行状况失败,即使我的路由可以连接并生成到 JMS 的消息.所以简而言之,Actuator 说它已关闭但它正在工作. 技术栈和技术说明: 春季启动:2.3.1.RELEASE 骆驼:3.4.1 阿尔忒弥斯:2.11.0 Artemis 已设置为使用用户名和密码 (artemis/artemis). 使用 org.apache.acti ..
发布时间:2022-01-19 08:47:12 其他开发

Camel中的消息自动过期

我有一个实现 Camel 和 ActiveMQ 的系统,用于在一些服务器之间进行通信.我想知道是否有办法在 X 段时间后自动过期并清除发送到队列的消息.由于原始服务器(填充队列)不知道是否有人在接收消息,所以我不希望我的队列增长到太大以至于崩溃.Bonus karma 指向可以提供帮助并提供 java dsl 方式来实现此功能的人. 解决方案 //2 分钟后过期消息长 ttl = Sy ..
发布时间:2022-01-19 08:46:38 Java开发

JsonMappingException 与 Apache Camel

我在骆驼路线上遇到了异常 原因:com.fasterxml.jackson.databind.JsonMappingException:没有为类 org.apache.camel.converter.stream.InputStreamCache 找到序列化程序,也没有发现创建 BeanSerializer 的属性(为避免异常,请禁用 SerializationFeature.FAIL_ON_E ..
发布时间:2022-01-19 08:46:19 其他开发

Apache Camel 路由中的 Spring Boot 属性使用

这可以在 Apache Camel 路由中使用 Spring Boot 属性吗?@Value 工作正常,但这是否可以直接放置在表达式的占位符中. 更新:我知道 PropertiesComponent,但除了 Applicaiton.yml 之外,这将是我不喜欢的另一种配置. application.yml sftp:主机:10.10.128.128用户:ftpuser1密码:ftpu ..
发布时间:2022-01-19 08:45:49 Java开发

Apache Camel:消息可以在正文中有多个对象(具有不同的类)吗?

我在 java 中几乎已经准备好使用 jms 和 Camel 的应用程序.弹出我们必须在交换/消息中添加其他信息.可以说这些附加信息实际上是新的 java 对象.将我的新对象添加到交换的最佳方式是什么? 我有很多 Camel 处理器处理如下所示的消息: 公共类 MyProcessor 实现处理器 {@覆盖公共无效进程(交换交换)抛出异常{String s = exchange.getIn( ..
发布时间:2022-01-19 08:45:41 其他开发