Package 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	Description
AggregateTestDriver(io.simplesource.kafka.spec.AggregateSpec<K,C,E,A> aggregateSpec, io.simplesource.kafka.dsl.KafkaConfig kafkaConfig)

Method Summary

Modifier and Type	Method	Description
void	close()
void	pollForApiResponse()
io.simplesource.data.FutureResult<io.simplesource.api.CommandError,io.simplesource.api.CommandId>	publishCommand(io.simplesource.api.CommandAPI.Request<K,C> request)
io.simplesource.data.FutureResult<io.simplesource.api.CommandError,io.simplesource.data.Sequence>	queryCommandResult(io.simplesource.api.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(io.simplesource.kafka.spec.AggregateSpec<K,C,E,A> aggregateSpec,
                           io.simplesource.kafka.dsl.KafkaConfig kafkaConfig)

Method Detail

publishCommand

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

queryCommandResult

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

pollForApiResponse

public void pollForApiResponse()

close

public void close()