轴突& CompletableFuture

Question

当我尝试在Axon中使用CompletableFuture时，我遇到了一些问题。例如：

CompletableFuture future = CompletableFuture.supplyAsync(() -> {

            log.info("Start processing target: {}", target.toString());
            return new Event();

        }, threadPool);

future.thenAcceptAsync(event -> {
            log.info("Send Event");
            AggregateLifecycle.apply(event);
}, currentExecutor);

在thenAcceptAsync -AggregateLifecycle.apply(事件)中有意想不到的行为。我的一些@EventSourcingHandler处理程序两次开始处理事件。有人知道怎么修吗？

我一直在看医生，我得到的一切都是：

在大多数情况下，DefaultUnitOfWork将为您提供所需的功能。它期望在单个线程中进行处理。

因此，我似乎应该以某种方式使用CurrentUnitOfWork.get/set方法，但仍然不能理解Axon。

Answer 1

您不应该异步地apply()事件。apply()方法将调用聚合的内部@EventSourcingHandler方法，并在工作单元完成(成功)时调度发布事件。Axon与Work (协调单个消息处理程序调用的活动)的工作方式，必须在管理该工作单元的线程中调用apply()方法。

如果希望异步发布事件，请使用使用异步传输的事件总线，并使用跟踪处理器。