apache-camel相关内容

Camel CXF POJO模式使用Java DSL

我有一个预先存在的 Web 服务“连接"(SOAP),如果可能,我想在不使用 Swing 框架的情况下调用.我遵循了使用 cxf/wsdl2java 工具生成我的 java 文件的联系优先开发. 我希望从 java 对象中提取用户名和密码,并将其放入 SOAP 对象中,然后发送到我的 localhost Web 服务. 当将 Connect 对象作为主体发送到“direct:start ..
发布时间:2022-01-19 08:31:38 其他开发

Apache Camel concurrentConsumers 与线程

我花了将近两天的时间来理解 Apache Camel 中的 concurrentConsumers 与线程的概念.但我真的不明白这个概念.谁能帮我理解这个概念.我正在使用骆驼 2.12.0. from("jms:queue:start?concurrentConsumers=5").threads(3, 3, "replyThread").bean(new SomeBean());pom.xm ..
发布时间:2022-01-19 08:31:19 其他开发

用 Camel 的表达语言获取和格式化昨天的日期

我在 Camel 的路径中使用日期: fileName=${date:now:dd-MM-yyyy} 但我现在需要的是 - 1 天.这可能吗? 解决方案 好吧,不直接.简单语言中的 date: 对象只能获取当前时间(或您放置在标头中的某个时间值 - 您可以在 java 或类似语言中执行此操作. 但你也可以这样做.创建一个类: 公共类 YesterdayBean{公共字符串 ge ..
发布时间:2022-01-19 08:30:26 其他开发

Camel DataFormat Jackson 使用蓝图 XML DSL 引发上下文异常

无论我将数据格式放在 XML DSL 蓝图中的哪个位置,我都会在不同的位置开始出现此错误.如果我删除它,它可以工作,但我当然不能将 JSON 转换为 POJO.???任何帮助或告诉我我做错了什么,我错过了什么.谢谢! 错误 无法启动捆绑包 passthrumt1.core/1.0.1.SNAPSHOT 的蓝图容器原因:org.xml.sax.SAXParseException:cvc-co ..
发布时间:2022-01-19 08:29:41 其他开发

我可以在一个包中有多个绑定注释类并且仍然在 Camel 中解组 CSV 吗?

我想要一个像 my.company.bindy 这样的包,其中包含多个类,所有类都使用 Bindy 注释进行注释.然后我想要骆驼路线,可以将 CSV 解组为其中一种类型.我已经完成了所有工作,但是如果我在包中有多个绑定注释类,则解组失败.这是因为 Bindy 试图将 CSV 行解组到包中的每个类中.并且一条特定的行不会正确编组到多个类中.我的数据格式在 Spring 中声明如下: ..
发布时间:2022-01-19 08:29:18 其他开发

Camel 使用 Simple DSL 将所有 CRLF 替换为 LF

我正在尝试用 LF 替换输入数据的 CRLF,但这会破坏路线.我的代码如下所示 from(fromEndpoint).convertBodyTo(byte[].class, "iso-8859-1").setBody(simple("body.replaceAll(\r\n, \n)")).... 如果我把 setbody 拿出来,它就完美了.我只想要平台相关的换行符 任何想法我做错了什 ..
发布时间:2022-01-19 08:28:09 Java开发

如何从 ActiveMQ 延迟使用 Apache Camel 中的消息

当客户端应用在 5 秒的时间内发送超过 1000 个请求时,我需要通过整形(排队)入站流量来节流. 我遵循的解决方案是:我有一个骆驼:油门将最大请求设置为 1000,将时间跨度设置为 5 秒.当超过阈值时,我正在捕获节流异常,并且在 onException 块内,我会将节流消息发送到 ActiveMQ 请求队列以供以后进一步处理,因为 Camel 基于 1000 req/5 sec 配置过载 ..
发布时间:2022-01-19 08:28:04 其他开发

如何在 camel-context.xml 中使用 xpath 来检查特定节点是否存在

我正在尝试开发基于内容的路由骆驼应用程序.此应用程序将查看文件夹 src/data 以查看是否存在具有节点 的 SOAP 请求文件,然后将该文件复制到目标/消息中,否则该文件将被复制到目标/其他. 你知道如何使用 xpath(或任何其他工具)来检查这种情况(我更喜欢使用 camel-context.xml 文件)吗? 这是我的骆驼背 ..
发布时间:2022-01-19 08:27:21 其他开发

带多个异常的骆驼重试控制

前言:我对 Camel 还很陌生,在尽可能地消化了 Camel 的实际操作之后,我正在将其调整到我正在进行的项目中.在这个项目中,我们有一些相当复杂的错误处理,我想确保我可以在我们对代码进行骆驼化时复制它. 在我们的项目中(与大多数情况一样),有一组我们想要重试的异常和一组我们不想重试的异常 - 但更具体地说,有一组我们比其他项目更想重试(并非所有可恢复的错误可以同样处理).在这种情况下,我 ..
发布时间:2022-01-19 08:27:13 其他开发

如何使用apache camel从mysql表中读取数据并写入另一个表

伙计们,我正在使用 Apache Camel 从 mysql 表中读取数据.我在控制台上成功打印了它.但是根据我的要求,我需要从一个mysql数据库中读取数据,然后使用一些条件对其进行过滤,然后将过滤后的数据插入另一个mysql数据库表中.我在下面发布我的代码.. 公共类camelJdbc {公共静态 void main(String[] args) 抛出异常 {最终字符串 url = "jdb ..
发布时间:2022-01-19 08:26:38 Java开发

Camel 的 CXF 组件未捕获 onException(Exception.class)

我有一个 camel-cxf 网络服务.我用来处理 CXF 的 SOAP 故障拦截器机制中的所有 SOAP 故障.效果很好. 我认为最好在同一层处理Camel层抛出的异常,并编写了一个简单的onException场景如下: onException(Exception.class).to("direct:MyWSExceptionHandler"); 每当抛出自定义异常时,我都期待 ..