<K,C,E,A> EventSourcedApp |
EventSourcedApp.addAggregate(AggregateSpec<K,C,E,A> spec) |
<K,C,E,A> EventSourcedApp |
EventSourcedApp.addAggregate(java.util.function.Consumer<AggregateBuilder<K,C,E,A>> buildSteps) |
EventSourcedApp |
EventSourcedApp.start() |
EventSourcedApp |
EventSourcedApp.withKafkaConfig(java.util.function.Function<KafkaConfig.Builder,KafkaConfig> builder) |
EventSourcedApp |
EventSourcedApp.withKafkaConfig(KafkaConfig kafkaConfig) |
EventSourcedApp |
EventSourcedApp.withScheduler(ScheduledExecutorService scheduler) |