Package | Description |
---|---|
io.simplesource.api | |
io.simplesource.kafka.testutils |
Modifier and Type | Method and Description |
---|---|
default FutureResult<CommandError,Sequence> |
CommandAPI.publishAndQueryCommand(CommandAPI.Request<K,C> commandRequest,
java.time.Duration timeout)
Chain together publishing a command then query the result.
|
FutureResult<CommandError,CommandId> |
CommandAPI.publishCommand(CommandAPI.Request<K,C> request)
Submit the given command ready for processing.
|
Modifier and Type | Method and Description |
---|---|
FutureResult<CommandError,CommandId> |
AggregateTestDriver.publishCommand(CommandAPI.Request<K,C> request) |
Copyright © 2019. All rights reserved.