apache-camel相关内容
我正在使用一个基本上允许文件系统导航的 API.我正在尝试从 API 返回的 JSON 中访问数据,以便对其执行功能. 下面是我使用访问 API 的代码.我曾尝试使用 unmarshal 来将返回的 JSON 转换为 Map. from("timer://foo?fixedRate=true&period=120000").log("检查文件").setHeader("授权", simpl
..
"period" 和 "fixedRate" 的确切用法是什么?这真的有意义吗,因为如果我指定了“周期"值,那么无论如何计时器都会在该间隔之后触发.那么“fixedRate"标志的确切用途是什么? 我很困惑,请帮帮我! 解决方案 您可以在以下位置阅读 java.util.Timer 的 javadoc api:http://docs.oracle.com/javase/7/docs/
..
我正在进行的一个项目需要从 SQS 读取消息,因此我决定使用 Akka 来分发这些消息的处理. 由于 Camel 支持 SQS,并且在 Consumer 类中内置了供 Akka 使用的功能,我认为最好以这种方式实现端点并读取消息,尽管我没有看到很多人的例子这样做. 我的问题是我无法足够快地轮询队列以保持队列为空或接近空.我最初的想法是,我可以让消费者以 X/s 的速率通过 Camel
..
在 Apache Camel 中,我尝试使用 XmlJsonDataFormat 进行从 XML 到 JSON 的快速转换.但是 XMLJSON (http://camel.apache.org/xmljson.html) 已被弃用,所以除了创建处理器之外,我不确定进行这种转换的最佳方法是什么. 有人知道 XmlJsonDataFormat 的替代方法吗? 解决方案 经过一些尝试,我
..
我有几个包(A、B 和 C)部署到一个 OSGi 容器,每个包都包含一个 CamelContext 和一些路由.我有另一个带有 CamelContext 的包(M),带有一个路由(用于收集监控数据)和一个 InterceptStrategy bean.我希望 M 中的 InterceptStrategy bean 自动应用于容器中的所有其他 CamelContext(即 A、B 和 C 中的那些)
..
我必须发出一个 POST 请求 curl -X POST --data-binary @auth.json http://somehost.com/auth{“回复": {“状态":“确定",“令牌":“622cee5f8c99c81e87614e9efc63eddb"}} ,这将返回带有令牌的 JSON 响应.auth.json 是一个带有登录名和密码的 JSON 文件.然后我有两个选择:将
..
我创建了一个 .eba 文件(企业包存档),其中包含一个具有 apache 骆驼路由(Java DSL)的 osgi 包.骆驼上下文定义是通过一个蓝图 xml 文件完成的.当我尝试在 Websphere Application Server 8.5 中部署 .eba 文件时,出现以下异常: org.apache.aries.application.modelling.ModellerExce
..
我正在尝试将 Actuator Camel 指标从 /actuator/camelroutes (路由指标,如交换/交易数量)转发/添加到 Prometheus Actuator 端点.有没有办法让我配置 Camel 以将这些指标添加到 PrometheusMeterRegistry? 我已尝试添加: camel.component.metrics.metric-registry=io.m
..
我想在 Apache Camel 2.14 中使用新的 Rest DSL 来创建一个 rest 接口.我想使用 Jetty 组件,我有一个这样的基本示例设置: Spring 安全配置
..
读过一次后,我似乎正在失去我的“内在"身体.请注意,我使用的是 Camel 的流缓存,并且输入是来自 http 组件的 json 文件.我有一个带有以下代码的处理器. log.debug("正文类型:" + exchange.getIn().getBody().getClass().getCanonicalName());log.debug("在 msg1:" + exchange.getIn
..
Apache Camel 提供两种使用线程池的解决方案: from("seda:stageName?concurrentConsumers=5").process(...) 和 from("direct:stageName").thread(5).process(...) 我想知道,这两种解决方案有什么区别?是否只是两种写相同的东西?有哪些用例? 解决方案 SEDA
..
您好,有人曾将 Camel 与 IBM 的 MQ 结合使用.我们正在考虑可能同时使用这两种产品,但没有这两种产品一起使用的示例. 解决方案 下面记录了我所能得到的最好的,说明为一个 Spring XML 应用程序上下文,它本身托管 CAMEL 上下文和路由.此示例与 IBM 本机 MQ JCA 兼容的资源适配器 v7.5、CAMEL 2.16、Spring core 4.2 一起使用.我已
..
如何使用 Apache Camel HTTP 组件进行分段文件上传? 解决方案 我不知道是否可以使用 HTTP 组件发送多部分表单. 如果您需要解决方法,您可以创建使用 Apache Http 客户端(及其 MultipartPostMethod)的 POJO Spring Bean.然后您可以将您的消息路由到该 bean: from("activemq:uploadQueue")
..
我对 Akka 的理解是它提供了一个模型,多个独立的线程可以通过这种模型以高度并发的方式相互通信.它使用“演员模型",其中每个线程都是有特定工作要做的“演员".您可以协调在什么条件下将哪些消息传递给哪些参与者. 我以前使用过 Camel,对我来说,现在 Akka 如此成熟且有据可查,我觉得它有点失去了光彩/实用性.据我了解,Camel 是关于企业集成,即将多个不同的系统集成在一起,通常以某种
..
我正在开发一个项目,它是集成项目,我们正在使用 Apache Camel 和 Apache Karaf.在项目中,我需要使用 Jira REST Java 客户端库.p> 所以我已经阅读了很多关于如何将非 OSGI 库包装到 OSGI 包的各种文章和线程,但我真的不确定我是否正确. 所以,我创建了一个 POM 文件,它依赖于所需的库.做了一个包,尝试部署到 Karaf,当然,Karaf 抱
..
我正试图围绕 Apache Camel,它似乎是一个轻量级 ESB.如果我正确理解 Camel/ESB,那么您可以将 Camel Route 视为节点和边的图.每个节点都是路由上的一个端点(可以消费/产生消息).每条边都是两个不同端点(1 个生产者和 1 个消费者)之间的路由. 假设这是正确的,我有一个实际问题:最佳实践对部署应用程序的 ESB/Camel Route 有什么要求?我应该将它
..
在使用 Spring DSL 与 Camel “玩耍"时,我遇到了以下问题.假设预期的消息流如下所示: 客户端向 CAMEL 发送带有 XML 正文的 HTTP POST 消息 CAMEL 将 HTTP POST 消息代理到服务器,URI 稍作修改,使用接收到的 XML 正文中的信息(例如:使用 XPATH 过滤掉某个参数) 在 CAMEL 收到回复后,CAMEL 使用 1 中收到的 X
..
Apache Camel 提供了几种执行数据转换的方法:其转换 EIP 的概念、自定义数据格式以及允许自定义类型转换器. 我有一种情况,我需要从 Camel 路线内部进行非常复杂的转换.我应该实现我自己的类型转换器、我自己的 DataFormat,还是应该实现 org.apache.camel.Expression 并将所有转换的东西放在那里: public class MyTransfo
..
我正在开发一个 ActiveMQ 系统,我真的不希望丢失消息.我的问题是重试消息导致我的消费者阻塞(而不是处理他们可以处理的消息).我想给失败的消息几天重试(例如,我的一个潜在目的地是我将通过 SFTP 访问的另一台服务器,该服务器可能已关闭),但我不希望消费者阻塞几天 -- 我希望它继续处理其他消息. 有没有办法告诉代理稍后重新发送消息?现在我正在考虑将消息从队列中取出并延迟放入,但我想知
..
我曾与 SEDA 和 direct 合作过,我还阅读了文档. 但我仍然无法想象 SEDA 和 direct 的用法.Vm 对我来说是新的. 请举例说明. 解决方案 至少有四种不同的机制可以让一个 Camel 路由直接将数据传递给另一个.“直接"是指不使用网络或某种形式的中间存储(文件、数据库).这些机制可以根据是否可以在CamelContext实例之间传递数据,以及它们是同步的
..