public final class EventSourcedApp extends Object
Constructor and Description |
---|
EventSourcedApp() |
Modifier and Type | Method and Description |
---|---|
<K,C,E,A> EventSourcedApp |
addAggregate(AggregateSpec<K,C,E,A> spec) |
<K,C,E,A> EventSourcedApp |
addAggregate(java.util.function.Consumer<AggregateBuilder<K,C,E,A>> buildSteps) |
CommandAPISet |
getCommandAPISet(String clientId)
Creates a CommandAPISet instance
Used for directly exposing a CommandAPISet from within a Simple Sourcing application
If creating a CommandAPISet from an external application, rather use the CommandAPISetBuilder DSL
|
EventSourcedApp |
start() |
EventSourcedApp |
withKafkaConfig(java.util.function.Function<KafkaConfig.Builder,KafkaConfig> builder) |
EventSourcedApp |
withKafkaConfig(KafkaConfig kafkaConfig) |
EventSourcedApp |
withScheduler(ScheduledExecutorService scheduler) |
public EventSourcedApp withKafkaConfig(java.util.function.Function<KafkaConfig.Builder,KafkaConfig> builder)
public EventSourcedApp withKafkaConfig(KafkaConfig kafkaConfig)
public EventSourcedApp withScheduler(ScheduledExecutorService scheduler)
public <K,C,E,A> EventSourcedApp addAggregate(java.util.function.Consumer<AggregateBuilder<K,C,E,A>> buildSteps)
public <K,C,E,A> EventSourcedApp addAggregate(AggregateSpec<K,C,E,A> spec)
public EventSourcedApp start()
public CommandAPISet getCommandAPISet(String clientId)
Copyright © 2019. All rights reserved.