| 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.