18得票1回答
Websphere集群中的全局单例

我需要在 WAS ND 8.0 集群下运行一个使用 Apache Camel(或Spring Integration)的组件。它们都会在启动时运行一些线程,并在正常关闭时停止它们。没有提供 WAS 管理的线程池没有问题,但这些线程必须同时在 单个 集群节点上运行。此外,它必须是高可用的,即在活...

17得票2回答
Apache Camel和Intellij Idea代码格式化

IntelliJ IDEA会像这样格式化驼峰命名的代码:from("direct:loop") .log("Loop: ${header[loopCount]}") .choice() .when(simple("header[loopCount] < 10...

17得票1回答
Apache Camel是否支持HTTP到HTTP路由?

我现在开始学习Camel。我已经了解了用于HTTP客户端的http4组件和用于HTTP服务器的jetty组件。 我看到很多例子都使用其中一个组件。 我想知道是否可以将它们组合在一起。 示例from("jetty:http://0.0.0.0:8080/myapp/myservice") ....

17得票2回答
使用Camel的分布式ActiveMQ

我正在学习ActiveMQ和Camel,目标是创建一个类似以下系统的小型原型: (来源: paulstovell.com) (big) 当在订单系统中下订单时,会向任何订阅者(即发布/订阅系统)发送消息,订阅者可以在处理订单方面发挥作用。 Orders,Shipping和Invoic...

16得票3回答
在Apache Camel中处理大型CSV文件的最佳策略

我想开发一个路由程序,轮询包含CSV文件的目录,并对每个文件使用Bindy进行解组,将其转换为Java对象并将其排队到ActiveMQ。但问题在于文件可能非常大(一百万行),因此我更喜欢逐行排队,但是我的问题在于Bindy最终返回一个java.util.ArrayList对象,其中包含所有行,...

16得票5回答
Apache Camel端点注入到直接路由“端点上没有可用的消费者”

我希望使用Camel从ActiveMQ接收消息,并根据消息内容(一个protobuf)发送一条或多条消息到Twitter。我编写了一个bean,从路由内部调用它,并使用注入将多个消息发送到“direct:xyz”端点。 然而,在运行时,Camel报错:2012-11-16 09:56:33,...

16得票2回答
无法访问Amazon SQS - InvalidClientTokenId

我在AWS上设置了一个SQS队列。我可以使用AWS CLI和我设置的IAM凭证完美地发送和接收消息。我想要做的是使用通过Spring配置的Camel从队列中消费消息。我尝试了这个例子,因为它非常清晰明了:https://github.com/christian-posta/camel-sqs-...

16得票3回答
普通队列 vs SEDA队列

作为Apache Camel的新手,我最近正在审查其长列表中的组件,并偶然发现它们支持SEDA队列组件。 这个页面对我来说毫无意义,所以我搜索了一下“SEDA队列”这个词,并找到了维基百科文章here。 阅读完那篇文章后,我无法区分SEDA队列和普通的“普通”队列之间的区别!两者都通过使用...

16得票1回答
Akka是否会使Camel过时?

我对Akka的理解是,它提供了一种模型,使得多个独立的线程可以以高度并发的方式相互通信。它使用“actor模型”,其中每个线程是一个“actor”,有特定的工作要做。您可以编排将哪些消息在什么条件下传递给哪些演员。 我以前用过Camel,我觉得随着Akka变得如此成熟和文档完善,它已经失去了...

16得票1回答
骆驼(Camel)的adviceWith方法在改变编织语句顺序时表现不同

我有以下路由用于演示目的from("direct:external") .routeId("external") .to("http4://www.third-party.com/foo").id("ext"); 为了测试,我想要: * 将http4端点替换为direct端点 ...