Package | Description |
---|---|
io.simplesource.api | |
io.simplesource.data | |
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,Sequence> |
CommandAPI.queryCommandResult(CommandId commandId,
java.time.Duration timeout)
Get the result of the execution of the command identified by the provided UUID.
|
Modifier and Type | Method and Description |
---|---|
Optional<CommandError> |
InvalidSequenceHandler.shouldReject(K key,
Sequence expectedSeq,
Sequence currentSeq,
A currentAggregate,
C command)
The sequence handler is responsible for accepting or rejecting commands executed against an out of date view
If expectedSeq == currentSeq this handler will not be invoked
If this handler is invoked, it means the is executing a command against an old version of the aggregate
|
Modifier and Type | Method and Description |
---|---|
static Sequence |
Sequence.first() |
Sequence |
Sequence.next() |
static Sequence |
Sequence.position(long pos) |
Modifier and Type | Method and Description |
---|---|
int |
Sequence.compareTo(Sequence o) |
boolean |
Sequence.isEqualTo(Sequence sequence) |
boolean |
Sequence.isGreaterThan(Sequence sequence) |
boolean |
Sequence.isGreaterThanOrEqual(Sequence sequence) |
boolean |
Sequence.isLessThan(Sequence sequence) |
boolean |
Sequence.isLessThanOrEqual(Sequence sequence) |
Modifier and Type | Method and Description |
---|---|
FutureResult<CommandError,Sequence> |
AggregateTestDriver.queryCommandResult(CommandId commandId,
java.time.Duration timeout) |
Modifier and Type | Method and Description |
---|---|
AggregateTestHelper.PublishBuilder |
AggregateTestHelper.publishCommand(K key,
Sequence readSequence,
C command) |
Copyright © 2019. All rights reserved.