io.simplesource.kafka.testutils

Class AggregateTestDriver<K,C,E,A>

java.lang.Object

io.simplesource.kafka.testutils.AggregateTestDriver<K,C,E,A>

public final class AggregateTestDriver<K,C,E,A>
extends Object

Constructor Summary

Constructors

Constructor and Description
AggregateTestDriver(AggregateSpec<K,C,E,A> aggregateSpec, KafkaConfig kafkaConfig)

Method Summary

Modifier and Type	Method and Description
void	close()
void	pollForApiResponse()
io.simplesource.data.FutureResult<CommandError,UUID>	publishCommand(CommandAPI.Request<K,C> request)
io.simplesource.data.FutureResult<CommandError,io.simplesource.data.Sequence>	queryCommandResult(UUID commandId, java.time.Duration timeout)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AggregateTestDriver

public AggregateTestDriver(AggregateSpec<K,C,E,A> aggregateSpec,
                           KafkaConfig kafkaConfig)

Method Detail

publishCommand

public io.simplesource.data.FutureResult<CommandError,UUID> publishCommand(CommandAPI.Request<K,C> request)

queryCommandResult

public io.simplesource.data.FutureResult<CommandError,io.simplesource.data.Sequence> queryCommandResult(UUID commandId,
                                                                                                        java.time.Duration timeout)

pollForApiResponse

public void pollForApiResponse()

close

public void close()