我正在使用 Axon 3.1.1 并想知道,
如何在我的配置文件中获取事件处理器列表,
我浏览了 springAmQPmessageSource 文件,但仍然不确定如何准确地做到这一点。
这样我就可以将我的事件传递给查询端的适当事件处理程序。
List<Consumer<List<? extends EventMessage<?>>>> eventProcessors = new CopyOnWriteArrayList<>();
更新
我正在从 kafka 主题中检索消息,并希望将它们连接到特定的事件处理程序,但由于我无法获得偶数处理器,我无法做到这一点。如果我使用的是 Axon 3.0.5,你能告诉我怎么做吗