java – Apache Camel动态消费者

2019-07-11 17:18:59 阅读：209 来源： 互联网

我创建了这个Camel路线

from("direct:pageExtraction")
            .bean(PageManager.class, "setProperties(*, ${headers})")
            .filter().method(PageManager.class, "exists").to("seda:pagePostProcessing").end()
            .to("seda:pageImposition");

            from("seda:pagePostProcessing")
            .bean(PageManager.class, "extractThumbnail(*, ${headers})")
            .bean(PageManager.class, "extractCMYKSeparation(*, ${headers})")
            .bean(PageManager.class, "persist(*, ${headers})")
            .bean(PageManager.class, "cleanUp(${headers})")
            .to("seda:pageImposition");

            from("seda:pageImposition")
            .bean(PageManager.class, "extractImposition(*, ${headers})")
            .to("seda:printQueue");

最后,seda：printQueue没有消费者,在这样的路线中发送消息显然工作正常.现在我想在路由初始化之后引入一个新的消费者,我认为可以用编程方式创建一个Spring bean,让Camel使用@Consume(uri =“seda：printQueue”)注释来获取bean,但是一旦我创建消费者,Camel就会抱怨

org.apache.camel.RuntimeCamelException: org.springframework.beans.factory.NoSuchBeanDefinitionException: No bean named '4965d710-b5c7-41cf-97e9-a42bdfcea894' is defined]

有什么想法吗？

[UPDATE]

我已经将错误追溯到创建这个新消费者的类,我正在实例化PrintQueue类,然后使用AutowireCapableBeanFactory将它集成到Spring上下文中,执行factory.autowireBean(printQueueInstance),然后是factory.initializeBean(printQueueInstance, id)其中id是4965d710-b5c7-41cf-97e9-a42bdfcea894,它出现在上面的异常中,所以我认为这必须是某种上下文范围问题,可能是我在main或web Spring上创建这个bean并且它无法通过Camel上下文访问,这可能吗？

解决方法:

由于通过使用“direct：”组件同步调用此路由,因此对于另一个bean的异步调用似乎不需要“seda：”.在这种情况下,使用Camel的bean方法为Java DSL调用bean似乎最简单.作为Camel bean文档中显示的示例：

http://camel.apache.org/bean.html

我会这样做：

// Send message to the bean endpoint
// and invoke given method.
from("direct:start")
  // do other stuff in your route
   .beanRef("beanName", "methodName");

标签：apache,java,spring,apache-camel
来源： https://codeday.me/bug/20190711/1434260.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

java – Apache Camel动态消费者