我正在做的是我试图从存储库中获取聚合,然后处理该特定事件并将其标记为新事件......以便查询识别它是一个更新事件。但问题是我无法获得那个特定的聚合。
我所做的是在这里:
LockAwareAggregate<CustomerAggregate, EventSourcedAggregate<CustomerAggregate>> lockCustomerAggregate =
customerEventSourcingRepository.load(command.getId().toString());
EventSourcedAggregate<CustomerAggregate> eventSourcedCustomerAggregate =
lockCustomerAggregate.getWrappedAggregate();
CustomerAggregate customerAggregate = eventSourcedCustomerAggregate.getAggregateRoot();
customerAggregate.updateAddress(command.getAddress());
我在 2.4.3 中使用了这段代码,它正在返回 aCustomerAggregate
但现在它正在返回 a LockAwareAggregate
。你能建议我哪里出错了。
您能否也分享
UnitOfWork work = DefaultUnitOfWork.startAndGet(message??);
提前致谢。