io.simplesource.kafka.testutils

Class AggregateTestHelper.PublishBuilder

java.lang.Object

io.simplesource.kafka.testutils.AggregateTestHelper.PublishBuilder

Enclosing class:

AggregateTestHelper<K,C,E,A>

public final class AggregateTestHelper.PublishBuilder
extends Object

Method Summary

Modifier and Type	Method and Description
AggregateTestHelper.PublishResponse	expecting(NonEmptyList<E> expectedEvents, A expectedAggregate) Publish the command and assert that the publishCommand was success generating the given events and aggregate_update update.
void	expectingFailure(java.util.function.Consumer<NonEmptyList<CommandError>> failureValidator) Publish the command and assert that the call failed.
void	expectingFailure(NonEmptyList<CommandError.Reason> expectedErrorCodes) Publish the command and assert that the call failed.

Methods inherited from class java.lang.Object

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

Method Detail

expecting

public AggregateTestHelper.PublishResponse expecting(NonEmptyList<E> expectedEvents,
                                                     A expectedAggregate)

Publish the command and assert that the publishCommand was success generating the given events and aggregate_update update.

Parameters:

expectedAggregate - the list of expected events

expectedAggregate - the expected aggregate state

expectingFailure

public void expectingFailure(java.util.function.Consumer<NonEmptyList<CommandError>> failureValidator)

Publish the command and assert that the call failed.

Parameters:

failureValidator - the failure reasons are provided for validation

expectingFailure

public void expectingFailure(NonEmptyList<CommandError.Reason> expectedErrorCodes)

Publish the command and assert that the call failed.

Parameters:

expectedErrorCodes - expected error codes contains in each of the generated failure reasons