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()
FutureResult<CommandError,CommandId>	publishCommand(CommandAPI.Request<K,C> request)
FutureResult<CommandError,Sequence>	queryCommandResult(CommandId 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 FutureResult<CommandError,CommandId> publishCommand(CommandAPI.Request<K,C> request)

queryCommandResult

public FutureResult<CommandError,Sequence> queryCommandResult(CommandId commandId,
                                                              java.time.Duration timeout)

pollForApiResponse

public void pollForApiResponse()

close

public void close()