Package | Description |
---|---|
io.simplesource.kafka.dsl | |
io.simplesource.kafka.testutils | |
io.simplesource.kafka.util |
Modifier and Type | Method and Description |
---|---|
<SC extends C> |
AggregateBuilder.build() |
Modifier and Type | Method and Description |
---|---|
<K,C,E,A> EventSourcedApp |
EventSourcedApp.addAggregate(AggregateSpec<K,C,E,A> spec) |
Constructor and Description |
---|
AggregateTestDriver(AggregateSpec<K,C,E,A> aggregateSpec,
KafkaConfig kafkaConfig) |
Modifier and Type | Method and Description |
---|---|
static <K,C> CommandSpec<K,C> |
SpecUtils.getCommandSpec(AggregateSpec<K,C,?,?> aSpec,
String clientId) |
Copyright © 2019. All rights reserved.