Axon — самый простой способ сделать проекцию во время запроса

Короткий ответ на это заключается в том, что нет простого/быстрого способа сделать это.

Тем не менее, безусловно, можно реализовать настройку «воспроизведение заданных событий во время запроса».

То, что я предлагаю вам сделать, состоит из нескольких шагов:

1. Создайте модель запроса, которую вы хотите вернуть, которая может обрабатывать события (используйте @EventHandler аннотированные методы в модели)
2. Создайте компонент, который может обрабатывать запрос, который вернет модель запроса на первом этапе (используйте для этого аннотированный метод @QueryHandler.
3. Компонент обработки запросов должен иметь возможность извлекать поток событий из EventStore. Если это основано на aggregateIdentifier, используйте метод EventStore#readEvents(String). Если вам нужен весь поток событий, вам нужно использовать метод StreamableMessageSource#openStream(TrackingToken) (примечание: интерфейс EventStore реализует StreamableMessageSource)
4. После обработки запроса создайте AnnotationEventHandlerAdapter, предоставив ему новый экземпляр вашей модели запроса.
5. Для каждого события в потоке событий, который вы создали в пункте 3, вызовите метод AnnotationEventHandlerAdapter#handle(EventMessage). Этот метод будет вызывать аннотированные методы @EventHandler для вашего объекта модели запроса.
6. Если поток исчерпан, вы гарантированно обработаете все необходимые события для вашей модели запроса. Таким образом, теперь вы можете вернуть модель запроса

Итак, опять же, я не думаю, что это слишком тривиально, легко или быстро настроить. Кроме того, в шаге 3 есть небольшая оговорка. Получение потока данного Агрегата на основе Идентификатора Агрегата выполняется довольно быстро/кратко, поскольку Агрегат обычно не имеет большого количества событий.

Однако извлечение потока событий на основе TrackingToken, которое вам понадобится, если ваша модель запроса охватывает несколько агрегатов, может гарантировать, что вы извлечете хранилище событий весь для создания экземпляров ваших моделей на лету. Конечно, вы можете точно настроить момент времени, когда вы хотите, чтобы поток событий возвращал события, поскольку вы имеете дело с TrackingToken, но изменения довольно велики, вы будете неполными и относительно медленными.

Однако вы заявили, что хотите получить события для данного совокупного идентификатора. Таким образом, я думаю, что это должно быть работоспособным решением в вашем сценарии.

Надеюсь это поможет!