问题标签 [apache-camel]

在 SericeMix 启动期间，我们正在尝试使用 ServiceA 在加载捆绑包时立即调用 ServiceB。Service2 具有 activemq 端点，我们需要调用该特定服务的方法。我尝试了 bean 标记中的 spring init-method 属性，这有助于在我调用 serviceB 的方法中自动触发 ServiceA 中的方法。我得到了端点没有可用的异常之类的异常。我假设只要 Service1 启动，它就不会获得需要使用 @Produce 注释 activemq 端点初始化的 service2 的实例。相同的服务在其他正常情况下工作正常。

异常：由以下 原因引起：org.apache.camel.CamelExchangeException：端点上没有可用的消费者：端点 [direct://ServiceB]。Exchange [消息：BeanInvocation public java.lang.String java.lang.Object.toString() with null]] 在 org.apache.camel.component.direct.DirectProducer.process(DirectProducer.java:46) 在 org.apache。 camel.component.bean.CamelInvocationHandler.invoke(CamelInvocationHandler.java:64) ... 还有 35 个

我复制粘贴代码块供您参考。

或者如果我需要达到这个要求，他们还有其他方式吗？我可以在 servicemix 启动期间自动加载服务（使用其他服务）。

我正在尝试从骆驼向远程代理发送请求/回复消息，但它超时。请参阅下面的配置：

为什么会这样？我意识到在远程代理上消费者的数量总是超过 1，即使我没有指定它应该有多少消费者。此外，当我删除 replyTo 目的地时，远程代理上仍然会出现该名称。

请问，有什么工具可以用来调试activemq，这样我就可以看到谁在从队列中挑选消息？

我正在尝试使用 cxf 组件从骆驼消费网络服务，如下所示：

该sendMessage方法没有响应，因此inOnly而不是to（尽管我尝试to替代时遇到了同样的问题）。问题是骆驼显然仍然希望得到响应，并且路由在等待响应时挂起。我想如果我让它尝试足够长的时间，它最终会超时。

为了清楚起见，我正在运行一个测试方法：

我看到了第一个调用的效果（即消息到达服务器），但不是第二个，并且该方法没有完成运行（再次，我假设它会在某个时候超时...如果是这样，超时时间很长：我在开始写这篇文章时运行了测试，它仍在运行）。

我错过了什么吗？它是一个错误吗？拥有没有响应的 Web 服务方法只是不好的做法吗？

顺便说一句，当测试有响应的方法时，它工作正常。

我正在开发一个 JBI 组件，它通过 Camel 路由调用另一个 JBI 组件。第二个组件执行某种长时间的操作，有时可能会挂断。我想配置我的骆驼路线，使其受到超时限制（比如说 5 秒）。它应该以某种方式表现为异步调用......有可能吗？

Grails 路由插件使在编译时创建 Apache Camel 路由变得轻而易举。有没有办法在运行时创建新路由？

我只需要验证此正则表达式语句是否会执行我想要的操作。

给定以下 json 字符串

我需要确保以下正则表达式

将始终返回字符串Provider":"后面的单词

在这种情况下，字符串Provider":"后面的单词是WebHook，但它可以是任何单词。我可以控制这个词，所以它永远不会包含非 ascii 字符。

我将在使用 java regex 引擎的 Apache Camel 中使用这个表达式。

谁能发现我的策略中的任何陷阱。

我想要做的是：

来自(...)
.replyWith( ) .from
(...)
.end()

因此，对我的生产者的响应来自另一个端点的消费，一个示例类似于队列的 REST 端点。

在 Camel 中是否有一种惯用的方式能够在不从 CamelContext 实例中获取 Endpoint 并手动检索内容并将其设置到 Exchange 中的情况下执行上述操作？

注册表是一个项目列表，带有指向哪里可以找到项目的指针，例如数据库表上的索引或图书馆的卡片目录。

如果我错了，请纠正我，根据这个定义，我对骆驼应用程序注册表的期望是客户端应用程序可以（取决于客户端协议）进行查找并基于元数据，选择特定服务并将其用作定义。

我想知道 Apache Camel 是否有任何与此相关的东西。我见过的大多数服务注册表文章/实现似乎只针对 SOAP 协议。

问候。

在查询camle jpa组件时

您如何从 bean 中的骆驼交换中获取记录列表？我曾尝试转换为 List ,Resultset 对象。但我得到了 ClassCastException 。

大家好，我在这个例子中使用了 Apache Camel 和 Apache CXF：

http://camel.apache.org/better-jms-transport-for-cxf-webservice-using-apache-camel.data/cxfcamelexample.zip

我想使用 AMQP 而不是 JMS 但我不知道配置，如果有人可以提供帮助，我还需要更改 QPID 客户端的版本，这会很棒，在此先感谢。