es-lite

@Configuration
public class EventsourcingConfiguration {

    @Bean
    public EventStore eventStore(EvenStoreProperties conf) {
        return EventStoreBuilder.newBuilder()
                .singleNodeAddress(conf.getHosts().stream().findAny().get(), 1113)
                .userCredentials(conf.getUser(), conf.getPassword())
                .build();
    }

    @Bean
    public EventDeserializer eventDeserializer() {
        return new JacksonEventDeserializer(List.ofAll(new Reflections("no.ks.fiks").getSubTypesOf(Event.class))
                .filter(p -> p.isAnnotationPresent(EventType.class))
                .toJavaSet());
    }

    @Bean
    public CmdHandler cmdHandler(EventStore eventStore, EventDeserializer deserializer) {
        EsjcStreamIdGenerator streamIdGenerator = (aggregateType, aggregateId) -> String.format("no.ks.fiks.autorisasjon-%s-%s", aggregateType, aggregateId);

        return new CmdHandler(
                new EsjcEventWriter(eventStore, streamIdGenerator),
                new EsjcAggregateReader(eventStore, deserializer, streamIdGenerator));
    }

}


@Component
public class ProjectionInitializer {

    private EsjcEventSubscriber subscriber;
    private EventDeserializer deserializer;
    private Set<Projection> projections;
    private HwmRepo hwmRepo;

    @Autowired
    public ProjectionInitializer(EventStore subscriber, EventDeserializer deserializer, Set<Projection> projections, HwmRepo hwmRepo) {
        this.subscriber = new EsjcEventSubscriber(subscriber);
        this.deserializer = deserializer;
        this.projections = projections;
        this.hwmRepo = hwmRepo;
    }

    @EventListener({ApplicationReadyEvent.class})
    void contextRefreshedEvent() {
        subscriber.subscribeByCategory(
                "no.ks.fiks",
                hwmRepo.get().orElse(null),
                new EsjcEventProjector(deserializer, projections, (hwm) -> hwmRepo.update(hwm)));
    }
}