apache-camel相关内容

从 Apache Camel 中的 JSON 正文访问数据

我正在使用一个基本上允许文件系统导航的 API.我正在尝试从 API 返回的 JSON 中访问数据,以便对其执行功能. 下面是我使用访问 API 的代码.我曾尝试使用 unmarshal 来将返回的 JSON 转换为 Map. from("timer://foo?fixedRate=true&period=120000").log("检查文件").setHeader("授权", simpl ..
发布时间:2022-01-19 08:25:48 Java开发

Apache Camel 计时器:“周期";与“固定利率"相比

"period" 和 "fixedRate" 的确切用法是什么?这真的有意义吗,因为如果我指定了“周期"值,那么无论如何计时器都会在该间隔之后触发.那么“fixedRate"标志的确切用途是什么? 我很困惑,请帮帮我! 解决方案 您可以在以下位置阅读 java.util.Timer 的 javadoc api:http://docs.oracle.com/javase/7/docs/ ..
发布时间:2022-01-19 08:25:39 其他开发

Akka、SQS 和 Camel 的消费者投票率

我正在进行的一个项目需要从 SQS 读取消息,因此我决定使用 Akka 来分发这些消息的处理. 由于 Camel 支持 SQS,并且在 Consumer 类中内置了供 Akka 使用的功能,我认为最好以这种方式实现端点并读取消息,尽管我没有看到很多人的例子这样做. 我的问题是我无法足够快地轮询队列以保持队列为空或接近空.我最初的想法是,我可以让消费者以 X/s 的速率通过 Camel ..
发布时间:2022-01-19 08:25:22 其他开发

替代 Apache Camel 中已弃用的 XmlJsonDataFormat

在 Apache Camel 中,我尝试使用 XmlJsonDataFormat 进行从 XML 到 JSON 的快速转换.但是 XMLJSON (http://camel.apache.org/xmljson.html) 已被弃用,所以除了创建处理器之外,我不确定进行这种转换的最佳方法是什么. 有人知道 XmlJsonDataFormat 的替代方法吗? 解决方案 经过一些尝试,我 ..
发布时间:2022-01-19 08:25:04 Java开发

OSGi 容器中的骆驼:将拦截策略应用于所有骆驼上下文

我有几个包(A、B 和 C)部署到一个 OSGi 容器,每个包都包含一个 CamelContext 和一些路由.我有另一个带有 CamelContext 的包(M),带有一个路由(用于收集监控数据)和一个 InterceptStrategy bean.我希望 M 中的 InterceptStrategy bean 自动应用于容器中的所有其他 CamelContext(即 A、B 和 C 中的那些) ..
发布时间:2022-01-19 08:24:22 Java开发

如何授权使用 Apache Camel?

我必须发出一个 POST 请求 curl -X POST --data-binary @auth.json http://somehost.com/auth{“回复": {“状态":“确定",“令牌":“622cee5f8c99c81e87614e9efc63eddb"}} ,这将返回带有令牌的 JSON 响应.auth.json 是一个带有登录名和密码的 JSON 文件.然后我有两个选择:将 ..
发布时间:2022-01-19 08:24:09 其他开发

无法在 Websphere 8.5 中部署包含通过 aries 蓝图定义的骆驼路由的 osgi 包

我创建了一个 .eba 文件(企业包存档),其中包含一个具有 apache 骆驼路由(Java DSL)的 osgi 包.骆驼上下文定义是通过一个蓝图 xml 文件完成的.当我尝试在 Websphere Application Server 8.5 中部署 .eba 文件时,出现以下异常: org.apache.aries.application.modelling.ModellerExce ..

Camel - 流缓存不缓存/无法转换?

读过一次后,我似乎正在失去我的“内在"身体.请注意,我使用的是 Camel 的流缓存,并且输入是来自 http 组件的 json 文件.我有一个带有以下代码的处理器. log.debug("正文类型:" + exchange.getIn().getBody().getClass().getCanonicalName());log.debug("在 msg1:" + exchange.getIn ..
发布时间:2022-01-19 08:22:44 Java开发

带有 IBM MQ 的 Apache Camel

您好,有人曾将 Camel 与 IBM 的 MQ 结合使用.我们正在考虑可能同时使用这两种产品,但没有这两种产品一起使用的示例. 解决方案 下面记录了我所能得到的最好的,说明为一个 Spring XML 应用程序上下文,它本身托管 CAMEL 上下文和路由.此示例与 IBM 本机 MQ JCA 兼容的资源适配器 v7.5、CAMEL 2.16、Spring core 4.2 一起使用.我已 ..
发布时间:2022-01-19 08:22:05 服务器开发

Apache Camel 多部分 HTTP 帖子(文件上传)

如何使用 Apache Camel HTTP 组件进行分段文件上传? 解决方案 我不知道是否可以使用 HTTP 组件发送多部分表单. 如果您需要解决方法,您可以创建使用 Apache Http 客户端(及其 MultipartPostMethod)的 POJO Spring Bean.然后您可以将您的消息路由到该 bean: from("activemq:uploadQueue") ..
发布时间:2022-01-19 08:21:59 Java开发

Akka 是否淘汰了 Camel?

我对 Akka 的理解是它提供了一个模型,多个独立的线程可以通过这种模型以高度并发的方式相互通信.它使用“演员模型",其中每个线程都是有特定工作要做的“演员".您可以协调在什么条件下将哪些消息传递给哪些参与者. 我以前使用过 Camel,对我来说,现在 Akka 如此成熟且有据可查,我觉得它有点失去了光彩/实用性.据我了解,Camel 是关于企业集成,即将多个不同的系统集成在一起,通常以某种 ..
发布时间:2022-01-19 08:21:45 其他开发

如何 OSGFy 库

我正在开发一个项目,它是集成项目,我们正在使用 Apache Camel 和 Apache Karaf.在项目中,我需要使用 Jira REST Java 客户端库.p> 所以我已经阅读了很多关于如何将非 OSGI 库包装到 OSGI 包的各种文章和线程,但我真的不确定我是否正确. 所以,我创建了一个 POM 文件,它依赖于所需的库.做了一个包,尝试部署到 Karaf,当然,Karaf 抱 ..
发布时间:2022-01-19 08:21:02 其他开发

应该如何打包/部署 ESB?

我正试图围绕 Apache Camel,它似乎是一个轻量级 ESB.如果我正确理解 Camel/ESB,那么您可以将 Camel Route 视为节点和边的图.每个节点都是路由上的一个端点(可以消费/产生消息).每条边都是两个不同端点(1 个生产者和 1 个消费者)之间的路由. 假设这是正确的,我有一个实际问题:最佳实践对部署应用程序的 ESB/Camel Route 有什么要求?我应该将它 ..
发布时间:2022-01-19 08:20:54 Java开发

Apache Camel:如何存储变量以供以后使用

在使用 Spring DSL 与 Camel “玩耍"时,我遇到了以下问题.假设预期的消息流如下所示: 客户端向 CAMEL 发送带有 XML 正文的 HTTP POST 消息 CAMEL 将 HTTP POST 消息代理到服务器,URI 稍作修改,使用接收到的 XML 正文中的信息(例如:使用 XPATH 过滤掉某个参数) 在 CAMEL 收到回复后,CAMEL 使用 1 中收到的 X ..
发布时间:2022-01-19 08:20:39 其他开发

哪种 Camel 构造适合转换?

Apache Camel 提供了几种执行数据转换的方法:其转换 EIP 的概念、自定义数据格式以及允许自定义类型转换器. 我有一种情况,我需要从 Camel 路线内部进行非常复杂的转换.我应该实现我自己的类型转换器、我自己的 DataFormat,还是应该实现 org.apache.camel.Expression 并将所有转换的东西放在那里: public class MyTransfo ..
发布时间:2022-01-19 08:20:20 Java开发

在未来的某个时间重试消息(ActiveMQ)

我正在开发一个 ActiveMQ 系统,我真的不希望丢失消息.我的问题是重试消息导致我的消费者阻塞(而不是处理他们可以处理的消息).我想给失败的消息几天重试(例如,我的一个潜在目的地是我将通过 SFTP 访问的另一台服务器,该服务器可能已关闭),但我不希望消费者阻塞几天 -- 我希望它继续处理其他消息. 有没有办法告诉代理稍后重新发送消息?现在我正在考虑将消息从队列中取出并延迟放入,但我想知 ..
发布时间:2022-01-19 08:20:11 其他开发

Apache Camel 中的 SEDA、VM 和 direct 有什么区别?

我曾与 SEDA 和 direct 合作过,我还阅读了文档. 但我仍然无法想象 SEDA 和 direct 的用法.Vm 对我来说是新的. 请举例说明. 解决方案 至少有四种不同的机制可以让一个 Camel 路由直接将数据传递给另一个.“直接"是指不使用网络或某种形式的中间存储(文件、数据库).这些机制可以根据是否可以在CamelContext实例之间传递数据,以及它们是同步的 ..
发布时间:2022-01-19 08:19:35 Java开发