如何在Axon中实现Replay事件？

// 聚合根
public class MyAggregate {

    private String state;

    @AggregateIdentifier
    private String id;

    public MyAggregate() {
        // 默认构造函数
    }

    @CommandHandler
    public MyAggregate(CreateAggregateCommand command) {
        apply(new AggregateCreatedEvent(command.getId()));
    }

    @EventSourcingHandler
    public void on(AggregateCreatedEvent event) {
        this.id = event.getId();
        this.state = "Created";
    }

    // 其他聚合根方法...

}

// 事件处理器
public class EventReplayHandler {

    private EventStore eventStore;
    private EventSourcingRepository<MyAggregate> repository;

    public EventReplayHandler(EventStore eventStore, EventSourcingRepository<MyAggregate> repository) {
        this.eventStore = eventStore;
        this.repository = repository;
    }

    public void replayEvents(String aggregateId) {
        EventStream eventStream = eventStore.readEvents(aggregateId);

        eventStream.forEach(event -> {
            MyAggregate aggregate = repository.load(aggregateId);
            aggregate.apply(event.getPayload());
        });

        MyAggregate aggregate = repository.load(aggregateId);
        // 获取重放后的状态
        String state = aggregate.getState();
        System.out.println("Replayed state: " + state);
    }

}

// 使用示例
public class Main {

    public static void main(String[] args) {
        // 创建Axon配置
        Configuration configuration = DefaultConfigurer.defaultConfiguration()
                .configureAggregate(MyAggregate.class)
                .configureEventStore(c -> new InMemoryEventStorageEngine())
                .buildConfiguration();

        // 获取事件处理器和事件存储库
        EventReplayHandler replayHandler = new EventReplayHandler(
                configuration.eventStore(),
                configuration.repository(MyAggregate.class)
        );

        // 重放事件
        replayHandler.replayEvents("aggregateId");
    }

}