识别并重新运行轴突中的特殊事件

Question

如果用户的注册事件失败，即使命令成功，我们希望为特定的事件处理程序重新运行特定的事件。

我们考虑使用跟踪事件处理器，但这似乎是从一个特定的时间点重播一组事件。然而，在我们的例子中，如果昨天有100个事件，我们只想在中间重新运行一个特定的事件。

目前，我们正在迁移到Axon，因此决定主要使用SubscriptionEventProcessors，因为它更同步（即错误在命令处理程序中传播）。我们确实了解订阅处理器是无状态的，因为它们只处理通过事件总线接收的内容。

Answer 1

为了更快地回答这个问题，我会用一个类似的回答，就像我在这个问题上发布的一样。

快速地重复我在那里的响应，它可以概括为：创建一个查询模型，其中包含“重新处理”所需的@eventHandler注释方法，这些方法可以作为Axon的AnnotationEventHandlerAdapter构造函数的输入提供。您可以根据需要使用筛选的事件流调用后续的AnnotationEventHandlerAdapter。结果，查询模型将更新为您需要的格式。

因此，您将在例外情况下执行该操作，而不是因为用户需要该信息而将其作为查询形式执行。无论如何，您仍将重新形成查询模型，但只是基于一组特定的事件。

顺便说一下，当涉及到事件处理器的选择时，我仍然选择TrackingEventProcessor。是的，这意味着事件失败不会发出回滚，但本质上事件表示它已经发生。因此，回滚是因为其他事情失败，处理该事件是不正确的；命令仍然成功了，所以它也应该保持这样。

最后，您正在寻找日志逻辑。您共享的跟踪扩展最近刚刚从测试状态中退出，因此可以安全地使用。接下来，可以通过将LoggingInterceptor配置为MessageHandlerInterceptor和MessageDispatchInterceptor来实现基本的日志记录（关于这方面的文档可以在这里找到）。如果您希望引入方面逻辑：Axon有一个类似的机制来绑定到每个消息处理程序中。请查看此页面上的HandleRenhancer/HandleRenhancerDefinition。

希望这一切能帮助你@Milindad！