在我的camel路径中，我可以使用以下命令获取原始消息但是，一旦我使用自定义聚合策略调用aggregate，工作单元就是空的，并且我无法在错误处理程序中检索到原始的in消息。
浏览 12提问于2016-09-06得票数 0
1回答
我正在使用camel，并使用JOLT transformer从JSON转换为JSON，当在spring boot上部署时，甚至在使用camel作为独立时，它都工作得很好。但是当我尝试切换到Camel-K时，我遇到了一些问题，我无法参考camel路由中的Jolt模板转换，甚至无法将其添加到部署中。谁有关于如何将J
浏览 14提问于2021-03-21得票数 0
回答已采纳
我们正在考虑使用事件驱动架构集成一些粗粒度的业务服务，这些服务的服务器端(REST)是用Java和.NET (C#)实现的。我们最初考虑使用RabbitMQ (和AMQP协议)作为一种中立和开放的方式(在这两种语言中有良好的客户端支持)，但这意味着必须支持另一个运行时(Erlang)。有人尝试过在ActiveMQ之上使用更丰富的Apache Camel ESB以发布-订阅EDA的方式集成.NET和Java服务吗？我是否错过了任何其他可能的建议，以通过此路线？
谢谢
浏览 9提问于2010-05-24得票数 5
在我的骆驼路由中，我使用队列中的消息；每条消息都包含标题"pad“(路径)和一个文件前缀。header.pad}")).log("Going to do other stuff here on ${header.file}");
我在这里有几个问题：-在运行此路由时，在看到日志行"tarring“之前，我看到多个”从<
浏览 1提问于2018-02-01得票数 0
回答已采纳
//End of Inner try catch .aggregate但是在我下面的聚合中，我得到了newExchange中的列表？它不应该传递Trade对象而不是List<Trade>吗？@Override
public Exchange aggregate(Exchange oldExchange, Exchange new
浏览 0提问于2019-05-16得票数 0
回答已采纳
我是Apache Camel的新手。有人能解释一下“直接开始”在Camel中的意思吗？
浏览 0提问于2012-03-09得票数 55
回答已采纳
2回答
我正在尝试理解Camel中的工作单元概念。我有一个简单的问题，希望这里有人能帮上忙。如果在路由Excachange时涉及多个路由，例如
from("direct:processMe"在我的示例中，一旦route1完成，SQS消息会从SQ
浏览 1提问于2018-07-17得票数 1
1回答
我正在解析一个CSV文件，将其拆分并通过camel中的多个处理器进行路由。有两个端点，一个具有错误数据，而另一个具有验证数据。
我需要在聚合数据方面的建议。我如何才能知道每个端点的文件中的所有10个都已完成，并领先于聚合器。我需要创建两个文件，一个包含有效数据，另一个包含来自单个文件的损坏数据。
浏览 1提问于2014-10-14得票数 3
回答已采纳
我正在尝试实现以下场景，我可以真正地使用和欣赏一些帮助。我使用ActiveMQ 5.14和camel 2.21。
在队列中，每条消息对应于一台机器。这些机器通过一个轮询使用者连接到队列，并且对使用者来说是无法区分的。应该将消息保存在队列中，直到一台计算机确认它已通过单独的请求到达正确的计算机为止。每次获取消息后，所述消息应锁定一段时间。我的方法是在每个fetch之后将消息<
浏览 1提问于2018-05-18得票数 0
回答已采纳
是否有一种使用自定义聚合策略将JSON解编组到Apache中的POJO的优雅方法？用AggregationStrategy丰富EIP是最好的选择。但是，我不知道如何在路由中将JSON解编组到POJO。我可以通过ObjectMapper做到这一点
浏览 0提问于2018-02-17得票数 1
当我在Camel上下文组件中向其端点发送消息时，我必须等待带有确认的响应消息。如果在超时时间内没有收到响应，则应向camel路由抛回异常。我尝试通过以下方式实现它:我使用多播来生成超时响应，同时将原始消息发送到端点。超时响应被延迟，如果在该超时之后没有接收到响应，则在路由上抛回超时异常。.log("no response")
.to(End
浏览 4提问于2016-04-15得票数 1
我发现带有选项transacted=true的JMS组件在聚合器中不能很好地工作。我的路由在到达聚合器之前是事务性的，在聚合器之后，我的路由不再是事务性的。所以消息不再在队列中了。这是正确的吗？
我需要对Camel做的是读取队列(RabbitMQ)中的所有消息，然后将它们转换成一个列表，最后将数据从列表中写入文件。所有这些都必须是transactional，，如果在路由中发生了一些错误，消息
浏览 10提问于2021-06-09得票数 2
这里是IBM网站的提交和退出:当程序从工作单元内的队列中获取消息时，该消息将保留在队列中，直到程序提交工作单元，但其他程序无法检索该消息。当程序提交工作单元时，该消息将永久从队列中删除。如果程序退出工作单元，IBM将通过使
浏览 2提问于2021-05-18得票数 1
我是Apache Camel的新手。我有一个关于如何将方法传递给路由中定义的bean的问题。我有以下路由定义： System.out.printl
浏览 2提问于2014-03-16得票数 0
3回答
普通队列与SEDA队列
、、、
作为Apache Camel的新手，我最近查看了它的长长的组件列表，偶然发现了它们对组件的支持。两者都包含通过使用异步队列来解耦系统的概念。
在这篇文章中，"SEDA“听起来就像是一个架构，它包含了在每个组件之间放置一个队列。这是正确的吗？但是如果它只是一个架构，那么为什么"SEDA“队列是一个特殊的Apache Camel组件呢？
浏览 2提问于2012-02-06得票数 15
回答已采纳
我对camel和编写一个小型POC以在现有的应用程序中实现来说都是新手。应用程序以xml请求作为输入，其中包含所请求的服务和相关数据。然后它一个接一个地调用这些服务。当成功调用服务时，我将在处理器中检索http响应代码，如下所示，并执行进一步的逻辑操作：<
浏览 0提问于2018-03-13得票数 1
回答已采纳
根据对象内容设置相应的标题
Endpoint2根据另一个头将消息路由到Endpoint2.2聚合所有接收到的消息，对其进行处理以获得mongodb条件，并将其发送到endpoint2.1 (completionSize在步骤2中计算，并保存在属性“endpoint22”中Enpoint2.1聚合所有消
浏览 3提问于2016-04-05得票数 1
回答已采纳
1回答
synchronous=true" /></camelContext>如果您只是使用纯JMS并去掉了CXF，那么camel正确地为路由的内部部分创建了一个新队列，尽管
浏览 3提问于2014-03-19得票数 0
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
