-
0 votesanswersviews
http请求 - camel的并发性
是否存在任何能够每秒处理> 20个http请求的骆驼消费者方法？我尝试使用restlet和jetty组件，但两者都失败了 . 例如，我为jetty组件设置了此配置： <bean id="jetty" class="org.apache.camel.component.jetty.JettyHttpComponent"> <pro... -
0 votesanswersviews
Camel：文件消费者组件“咬掉的东西超过它可以咀嚼”，管道因内存不足而死亡
我在Camel中定义了一个类似于这样的路由：GET请求进来，文件在文件系统中创建 . 文件使用者选择它，从外部Web服务获取数据，并通过POST将结果消息发送到其他Web服务 . 简化代码如下： // Update request goes on queue: from("restlet:http://localhost:9191/update?restletMethod=pos... -
0 votesanswersviews
Apache Camel：将同步直接转换/替换为异步
我的问题非常接近这个讨论：https://issues.apache.org/jira/browse/CAMEL-4863 . 我也被直接的同步行为 grab 了 . 我设计了这样一个应用程序： Route1：from（direct：step1-in）.process（...） . to（direct：step1-out） Route2：from（direct：step2-in）.process（... -
1 votesanswersviews
Apache Camel - IT基础架构的主干？
我有一堆网络服务 . 这些服务使用不同的语言编写，并公开REST API . 前端网站访问这些服务 . 请求通过nginx服务器代理，该服务器执行负载 balancer 和连接管理 . 这是坚如磐石的，非常高效 . 我正在考虑用Apache Camel替换nginx以利用其强大的中介和集成模式 . 我有几个问题，因为我是Java生态系统的新手 . Apache Camel的表现如何？码头终点的... -
3 votesanswersviews
Apache Camel GenericFileOperationFailedException：'Cannot rename file' locks exchange
我们有一个基于Camel v2.16.1的集成系统，它运行在Jboss v6 Linux平台上 . 有多个接口同时运行，每个接口具有不同的轮询速率 . 我们间歇性地遇到“无法重命名文件”问题，因为Camel无法备份到'done'文件夹，成功处理并从FTP源传输文件 . 重新启动camel应用程序可以解决问题 . 基本上，由石英调度程序触发的定期间隔，路线： 通过FTP从源中获取文件， 处理... -
1 votesanswersviews
Camel与ActiveMQ的死信队列？
我正在使用Dead Letter Channel EIP，正如Camel docs for Dead Letter Channel所描述的那样 . 这是我的camel.xml（删除了 Headers ） <camelContext id="camel" xmlns="http://camel.apache.org/schema/spring">... -
0 votesanswersviews
使用特定于路由的DLQ配置Java / Camel / AMQ
这里是Java 8 / Camel 2.19.x / AMQ 5.15.x. 我有一个Java应用程序，它使用Camel消耗AMQ队列中的消息，处理这些消息，并对它们进行处理 . 有时，路由的输出将处理结果重新放回另一个队列以进行进一步的下游处理，但不总是/必然 . 典型的Java / Camel / AMQ设置 . 我的每个路由（我使用的是Camel XML DSL）都有一个配置好的 <o... -
0 votesanswersviews
如何在 Spring 季批量停止文件传输
我创建了一个弹出批处理作业，用于从本地目录读取文件，并使用Camel-spring-batch通过ftp将其上载到远程目录 . 我正在使用chunk做同样的事情 . 我的 Spring 季批处理作业配置如下： <bean id="consumerTemplate" class="org.apache.camel.impl.DefaultConsumerTempl... -
1 votesanswersviews
Apache Camel同步多个消费者
由于持久性，我有两个运行相同Web应用程序的tomcat服务器实例 . 这些Web应用程序使用Apache-camel lib使用ActiveMQ的一些队列/主题 . 我的问题是如何同步这两个消费者，以便只有一个消费者可以获得特定的消息 . 我的意思是ActiveMQ在每个节点上发送不同的消息 . -
0 votesanswersviews
camel endpoints 是全局的，并在同一台服务器上的多个JVM上共享吗？
假设一个camel上下文实现了一个从 endpoints （direct：// simpleEndpoint）消耗的路由，另一个java程序使用生成器模板在其main方法中发送到该 endpoints . 消息会收到消息吗？ 现在，我无法做到这一点？有没有其他方法可以通过向 endpoints 发送虚拟消息来进行测试？ -
0 votesanswersviews
什么是在apache camel中路由消息的最佳方式
我正在使用Apache Camel中的消息管道，并且可以在设计上使用一些输入 . 基本上，消息进入管道并需要在人工触发的过程手动批准/拒绝每条消息之前存储在某处 . 我想要一些有弹性的东西，这样即使系统停机，消息也不会丢失 . 我正在考虑将每个消息转换为一个简短的文本文件，并让camel使用该文本文件 . 但这种方式看起来很笨重 . 有谁知道更好的方法吗？ 谢谢！ -
28 votesanswersviews
Apache Camel 生产环境 者和消费者
我很难绕过这个概念 . 我正在尝试实现一个 endpoints ，该 endpoints 在tcp端口上侦听专有格式的传入消息，然后转换消息并让camel接管转发和路由 . 我是否正确理解Producer负责将消息发送到 Endpoint 并且 Consumer 从该 endpoints 接收它们？ 在研究接口时，我无法弄清楚这些对象之间的消息流，特别是在消费者部分 . Consumer 仅定... -
2 votesanswersviews
Apache Camel术语的细微之处
我正试图围绕Apache Camel，在今天早上花了一些时间阅读在线Camel文档以及Javadocs之后，我有一些问题似乎无法找到答案 . 所有 endpoints 都是消费者或 生产环境 者（或两者）是真的吗？所有处理器都是 endpoints 是真的吗？是否有任何 endpoints 不是处理器？ 邮件头和Exchange之间有什么区别？交换被认为是"message con... -
1 votesanswersviews
如何在camel处理器中获得用户角色？ （Spring安全REST服务Camel）
我使用Spring安全性来保护对服务器上的休息服务的访问 . 应用程序使用Camel框架来处理请求/消息 . 因此，当请求通过spring安全性时，然后将它转换为Exchange类（我正在使用CXFRS组件），并由camel处理器准备进一步处理 . 处理交换的方式应取决于用户角色，但是： 如何从交换中带出用户？ -
1 votesanswersviews
使用Java在apache camel中为自定义组件配置使用者
假设我有一个Jetty组件comp1和自定义组件comp2，其中comp1生成一个交换，comp2使用它 . 如何在comp2的使用者中交换Jetty组件 . 到目前为止，我已经观察到我们可以在消费者的poll（）方法中获得它 - SomeEndpoint endpoint = camelContext.getEndpoint（“someURI”，SomeEndpoint.class）; 但在s... -
1 votesanswersviews
Camel组件：是否可以创建仅消费者组件？
我陷入两难境地 . 我有一个基于GET的REST服务和一个基于POST的REST服务 . 我必须为每个创建自定义Camel组件 . 我们可以创建仅消耗的Camel组件吗？同样，是否可以创建仅生成的自定义Camel组件？ 如果仅使用Camel组件，我们如何向其提供消息以供消费？因为如果我们写入（“consumeOnly：someURI”），这会使这个组件成为 生产环境 者 . 并且将调用consum... -
5 votesanswersviews
在Camel @Produce中产生了什么，而@Consume消耗了什么？
作为一个无关紧要的不太自以为是的观点，我发现阿帕奇骆驼文档太过冒昧，因为假设读者已经有了骆驼的背景 . 通常情况下，Web服务提供者是 生产环境 者，它生成的服务的客户是消费者 . 我们来看看http://camel.apache.org/pojo-producing.html . 其中说，有两种不同的方式向Camel Endpoint发送消息 . @EndpointInjecct (uri ..... -
0 votesanswersviews
骆驼的制作人界面
生产环境 者界面的apache camel API doc说"Producer interface provides a channel on which clients can create and invoke message exchanges on an Endpoint" . （https://camel.apache.org/maven/current/camel... -
0 votesanswersviews
骆驼 - 多种类型的消费者
我目前正在开发一个将单独运行的服务 . 我想以多种格式为用户提供服务 . 那就是用户可以通过访问服务 打个电话 制作Web服务 发布到队列 上传文件 有没有办法，我可以用Camel提供 . 即骆驼站在所有这些前面，并提供路由？ -
2 votesanswersviews
骆驼 - 分裂和聚合异常
我想以csv文件的形式向webservice endpoints 发送按摩，拆分消息以分别处理每个csv行，聚合检查的异常，并发送带有异常摘要的响应： 我的路线是： <route> <from uri="cxf:bean:MyEndpoint" /> <split strategyRef="myAggregateStrat... -
2 votesanswersviews
Camel JMS对象消息有效内容在使用Websphere MQ时从对象转换为字节消息
我正在使用apache camel（Fuse 2.10.x），用肥皂覆盖http和肥皂而不是jms . JMS消息从Object消息转换为Byte消息格式，这会导致读取消息时出现问题 .我在JBOSS 5.0 GA环境中为websphere MQ使用JNDI连接 . <tx-connection-factory> <jndi-name>MQConnFactory... -
1 votesanswersviews
Apache Camel迭代List
我是Apache Camel的新手，我在理解如何实现简单的集成任务时遇到了问题： REST服务通过Apache Camel路由调用Spring Bean Spring Bean返回类的集合（ArrayList） 我需要迭代集合中的每个项目，并通过自定义转换器将其转换为另一种类型 . 我似乎应该使用Split和Aggregator，但是如何约束Aggregator来使用原始列表中的所有项... -
2 votesanswersviews
Akka Camel多个消费者
我正在使用akka camel来消费来自activemq的消息，我正在试图弄清楚如何在多台机器上部署这个消费者，而不会重复消息 . 在这种情况下，我正在消费来自主题的消息，而activemq应该知道我在各种机器中有一个akka系统，而不是各种单独的独立系统 . 我尝试使用akka集群实现这一点，但是使用前端订阅后端集群的示例没有帮助，因为我的“后端”actor是activemq消费者本身，我不能告... -
1 votesanswersviews
Camel文件拆分和聚合
我正在处理一个CSV格式的大文件，我用split来破解CSV . 以下是示例文件格式： **Item1,Item2,Item3,Item4 Item1,Item5,Item7,Item2** 这是我的路线信息： <route> <from uri="file://Data/groupedDocs?preMove=staging&amp;delete=f... -
0 votesanswersviews
ActiveMQ消费者消失了
我们正在使用ActiveMQ 5.10代理进行以下配置 JVM堆48G，其中70％分配给memoryUsage 70G存储和1G温度 我们使用Apache camel 2.10.2路由来消耗队列中的消息 . 收到消息后，我们使用spring的jmstemplate使用 asyncSend 创建~4k个较小的消息/接收消息并将它们发布到另一个队列 . 我们为使用pooledconnect... -
1 votesanswersviews
Camel ActiveMQ：使用基于JMSTimestamp的消息
我已经定义了一个 Route ，它消耗来自队列的消息没有任何问题，现在我正在尝试使用已经在队列中的消息12小时，我有想法使用 selector ，但不知道如何使用它与 JMSTimestamp 符合12小时标准 . 这是 Route ： <route id="INBOUND.RECEIVE.IN"> <from uri="ac... -
1 votesanswersviews
接收来自Camel Twitter制作人的多条推文
使用Apache Camel 2.15.0，我试图触发一条路由，该路由应检索某个用户的最新推文并将其发送给消费者 . 目前，我只能使用最新的推文生成单个交换消息 . 我如何调整这个以返回我的推文列表？ 路线配置如下： from("direct:twitter") .pollEnrich("twitter://timeline/user?type=direct&... -
4 votesanswersviews
Apache Camel动态消费者
我创建了这个Camel路线 from("direct:pageExtraction") .bean(PageManager.class, "setProperties(*, ${headers})") .filter().method(PageManager.class, "exists")... -
0 votesanswersviews
Apache Camel多个消费者
我已经和Apache Camel合作了一段时间并做了一些基本的东西，但现在我正在尝试创建一条路线，我可以让多个“消费者”到同一条路线，或者在路线上添加消费者然后处理消息 . 我的想法是让事件触发事件驱动的消费者，然后从ftp读取文件 . 我打算做这样的事情： from("direct:processFile") .from("ftp://localhost:21/... -
0 votesanswersviews
Camel文件轮询：在再次轮询之前完成处理批处理
我有一个文件丢弃 endpoints ，我从中查询 . 我需要在接收文件时按顺序轮询文件，并且我使用cron表达式仅在当天的某些时间进行轮询 . 这是我的文件输入： file:///tmp/input?idempotent=true&amp;moveFailed=/tmp/error&amp;readLock=changed&amp;readLockCheckInterva...