Camel 之路,每一步都由事件驱动

lxkprmvk  于 2023-05-17  发布在  Apache
关注(0)|答案(1)|浏览(110)

这是我的 Camel 路线。

<route>
    <from uri="direct:foo"/>
    <to uri="publish event1" />
    <from uri="kafka event1"/>
    <to uri="publish event2" />
    <from uri="kafka event2)"/>
    <to uri="publish event3" />
    <from uri="kafka event3)"/>
    <to uri="publish event4" />
    <from uri="kafka event4)"/>
</route>

我希望能够:

  • 让每个方法都对Kafka的事件做出React(除了第一个)。
    以上方式只是概念上的表示,不允许一条路由多个from。

我甚至不确定Camel是否是这个“暂停”模式下的编配的正确选择。
有什么建议吗?基本上,我希望每一步都能对事件做出React,并为下一步发布更多的事件。

nwlqm0z1

nwlqm0z11#

我不太明白。也许你可以添加更多的细节,因为我知道你需要使用拦截日志传入根工作的每一个jms消息

interceptFrom("jms*")
  .to("log:incoming");

from("jms:queue:order")
  .to("bean:validateOrder")
  .to("bean:processOrder");

对于模式详细信息:https://camel.apache.org/components/next/eips/intercept.html

相关问题