cqrs - 如何在 axon 3.1.1 中获取事件处理器列表

Question

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

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

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

score 1 · Accepted Answer

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

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

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

1 回答 1