当前位置: 首页 > 知识库问答 >
问题:

Apache Camel:从Bean消费

庄欣然
2023-03-14
from("bean:MyBeanCall?method=beancallMethod(String1)")
.bean(MyBeanCall.class,"beancall('String1')");
public static void beancall(String test, @Header("theHeader") String header, @Header("JMSCorrelationID") String correlationID){...}

但是我需要在from()中调用,以生成带有String1和头部的使用者。

共有1个答案

籍英叡
2023-03-14

来自文档http://camel.apache.org/bean.html

bean:endpoint不能定义为路由的输入;也就是说,您不能从中消费,您只能作为输出从某个入站消息endpoint路由到beanendpoint。因此,考虑使用Direct:或Queue:endpoint作为输入。

根据您的需求,您可以使用计时器、scheduleRoutingPolicy、SimpleScheduleRoutingPolicy或CronScheduleRoutingPolicy来触发路由。

 类似资料:
  • 我正在尝试向异步路由发送消息,但它不起作用。我刚刚在github上创建了一个项目来模拟这个问题

  • 我正在使用apache camel cxf开发一个Web服务(肥皂),我遇到了这个错误。 Java . lang . illegalargumentexception:Part { http://blue print . camel . ngt . TN/}返回的类型应为[ltn . ngt . camel . blue print . WB _ subscriptions;,而不是org . A

  • 我有一个restendpoint示例。org,返回表单的json响应 我的路线是这样的 我读过关于轮询消费者的内容,但找不到如何继续轮询endpoint的示例,直到它返回“success”响应。 是否应该使用轮询消费者?如果是这样的话,可以举一个与我的案例相关的例子。用于轮询restendpoint的任何其他资源都非常有用。

  • 我正在努力寻找一个成熟的例子,说明如何在Spring Boot框架中使用ApacheCamel进行轮询。 我已经看过了:https://camel.apache.org/manual/latest/polling-consumer.html除此之外:https://camel.apache.org/components/latest/timer-component.html但是代码示例不够广泛,我

  • 我试图在聚合器完成后获得一个回复,但是我得到一个异常,我没有指定任何聚合器子项,但是当我指定一个。to()endpoint我没有收到聚合结果。。。这可能吗? 控制器: 聚合器:

  • 是否可以在MDB(消息驱动Bean)中为“目的地”动态分配运行时值? 我还尝试了ejb-jar.xml方法,但是“activation-config-property-name”=“destination”的值被理解为队列的文字物理名称。因此我无法对资源进行JNDI查找。 从属性读取和分配目标或使用-d参数传递值的正确方法是什么?