这是我的 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,并为下一步发布更多的事件。
1条答案
按热度按时间nwlqm0z11#
我不太明白。也许你可以添加更多的细节,因为我知道你需要使用拦截日志传入根工作的每一个jms消息
对于模式详细信息:https://camel.apache.org/components/next/eips/intercept.html