问题标签 [apache-camel]

为弹簧注入端点给出的示例如下：

如何设置客户端模式端点，以便连接到另一台服务器上的特定端口？

如何配置端点以侦听入站连接？（该示例似乎是一个侦听器，如其描述性 ID 所示，但为什么呢？）

注意：我实际上并没有使用 HL7 协议或编解码器。我将为专有协议编解码器开发自己的。

我正在尝试从 ActiveMQ 开始一个简单的演示，它将演示 TCP 到 TCP 的路由。我在我的 activemq.xml 配置文件中的骆驼上下文中对端点和路由进行编码。

知道为什么这不起作用吗？

AMQ 服务器似乎没有打开监听端口。

编辑：作为一个简单的演示，这里的意图是使用两个 telnet 终端（A 和 B）连接到 ActiveMQ，并能够通过消息队列服务器将消息从一个路由到另一个。稍后，我可能会尝试根据内容进行过滤或路由。

我正在尝试设置一个简单的 activemq 和 mina 演示。我在 activemq.xml 文件中编辑了 camelContext 以包含两个 mina tcp 套接字、两个队列和路由，如下所示：

listenerA -> qA -> listenerB
listenerB -> qB -> listenerA

目的是在两个 telnet 会话之间有两种方式通过。稍后，我将在每个侦听器上添加更多花哨的功能，例如过滤、路由到主题和我自己的编解码器。

这是我的骆驼上下文：

当我启动 activemq 时，我得到一个异常：

org.apache.camel.NoSuchEndpointException：找不到端点：mina:tcp://localhost:42000?textline=true

我是否明确需要添加一个 mina bean？如果是这样，在哪里以及如何？

通过 RouteBuilder 在 Camel 上下文中使用路由时，以下之间的实际区别是什么：

1) 从(A).to(B).to(C)；

2）从（A）到（B）；从（B）到（C）

我正在尝试运行骆驼示例“camel-example-spring-jms”（也在http://activemq.apache.org/camel/tutorial-jmsremoting.html）。但是，当我尝试使用“org.apache.camel.spring.Main”类启动 Camel 时，我收到错误消息

“配置问题：找不到 XML 模式命名空间的 Spring NamespaceHandler [ http://activemq.apache.org/schema/core] ”

[注意：当我使用 Maven 命令 "mvn exec:java -PCamelServer" 时，我能够很好地运行该示例]

有人可以帮助我了解可能导致这种情况的原因。潜在的解决方案提示也不会受到伤害:)

++++++ 错误堆栈 +++++

++++++

我是一个 ActiveMQ / Camel 菜鸟，有一个特定的场景，我首先想知道是否有可能，其次是否有人​​可以提供一点方向。

基本上我需要在队列之外执行动态限制。IE 能够在运行时设置从队列中消耗特定消息组的速率。

因此，例如，我可能会添加一组以每秒 10 次的速度消耗的消息，另一组应该以每秒 1 次的速度消耗，依此类推。

我知道在骆驼中设置路由和将消息分组到队列等的基础知识，但只是无法从文档中弄清楚这一点。

将 Apache Camel 用于异步请求是否有意义？或者我应该使用 JMS 服务器使用简单的 MoM。我不需要任何企业集成模式。

任何帮助都会很有用。

我无法让 Apache Camel 插件在 grails-1.1.1 中运行。这是我采取的步骤：

我有一个骆驼路由文件，我想根据通过 Grails 域类访问的某些数据库记录来填充/配置它。但是，我似乎无法从 MyRoute.groovy 访问域类（或 spring 上下文中的任何内容）。关于如何使之成为可能的任何想法？

我在 Grails 上尝试了建议：在 Bootstrap 代码的 destory 闭包中访问 spring bean？但这似乎不起作用。

我有一个用 Java DSL 编写的骆驼路线定义，如下所示：

这使用 Throttler 连接我的两个端点，将消息流限制为每秒 200 条消息。

我正在寻找一种在运行时更改 maximumRequestCount / 秒的方法。所以我需要以某种方式到达被调用的 Throttler 实例并更改属性。

如何访问 Throttler？