-1

我正在使用 Axon 3.1.1 并想知道,
如何在我的配置文件中获取事件处理器列表,
我浏览了 springAmQPmessageSource 文件,但仍然不确定如何准确地做到这一点。
这样我就可以将我的事件传递给查询端的适当事件处理程序。

List<Consumer<List<? extends EventMessage<?>>>> eventProcessors = new CopyOnWriteArrayList<>();

更新
我正在从 kafka 主题中检索消息,并希望将它们连接到特定的事件处理程序,但由于我无法获得偶数处理器,我无法做到这一点。如果我使用的是 Axon 3.0.5,你能告诉我怎么做吗

4

1 回答 1

1

如果您使用的是SpringAmqpMessageSource,则无需检索eventProcessors已共享的列表,因为 Axon 会自动为您订阅所有事件处理组件。随后,Message Source 接收到的事件将自动推送到您查询端的所有侦听器。

由于这一切都包含在引擎盖下的 Axon 基础设施中,因此没有一次性的方法可以将它们从其中拉出来供您自己使用(除了可能自己接线之外)。因此,您不必自己执行此操作。

但是,也许我在这里遗漏了一个明显的观点。您能否详细说明一下为什么首先需要处理程序列表?

于 2018-02-07T13:38:55.833 回答