com.lightbend.lagom.javadsl.testkit

Class PersistentEntityTestDriver<C,E,S>

Object

com.lightbend.lagom.javadsl.testkit.PersistentEntityTestDriver<C,E,S>

public class PersistentEntityTestDriver<C,E,S>
extends Object

A testing utility for verifying that a PersistentEntity emits expected events and side-effects in response to incoming commands.

It also verifies that all commands, events, replies and state are serializable, and reports any such problems in the issues of the Outcome.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	PersistentEntityTestDriver.Issue
static class	PersistentEntityTestDriver.NoSerializer
static class	PersistentEntityTestDriver.NoSerializer$
static class	PersistentEntityTestDriver.NotDeserializable
static class	PersistentEntityTestDriver.NotDeserializable$
static class	PersistentEntityTestDriver.NotEqualAfterSerialization
static class	PersistentEntityTestDriver.NotEqualAfterSerialization$
static class	PersistentEntityTestDriver.NotSerializable
static class	PersistentEntityTestDriver.NotSerializable$
static class	PersistentEntityTestDriver.Outcome<E,S>
static class	PersistentEntityTestDriver.Outcome$
static class	PersistentEntityTestDriver.Reply
static class	PersistentEntityTestDriver.Reply$
static interface	PersistentEntityTestDriver.SideEffect
static class	PersistentEntityTestDriver.UnhandledCommand
static class	PersistentEntityTestDriver.UnhandledCommand$
static class	PersistentEntityTestDriver.UnhandledEvent
static class	PersistentEntityTestDriver.UnhandledEvent$
static class	PersistentEntityTestDriver.UsingJavaSerializer
static class	PersistentEntityTestDriver.UsingJavaSerializer$

Constructor Summary

Constructors

Constructor and Description
PersistentEntityTestDriver(akka.actor.ActorSystem system, PersistentEntity<C,E,S> entity, String entityId)

Method Summary

Modifier and Type	Method and Description
java.util.List<PersistentEntityTestDriver.Issue>	getAllIssues() Accumulated issues from all previous runs.
PersistentEntityTestDriver.Outcome<E,S>	run(Object... commands) The entity will process the commands and the emitted events and side effects are recorded and provided in the returned Outcome.
PersistentEntityTestDriver.Outcome<E,S>	run(scala.collection.Seq<C> commands) The entity will process the commands and the emitted events and side effects are recorded and provided in the returned Outcome.

Methods inherited from class Object

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

Constructor Detail

PersistentEntityTestDriver

public PersistentEntityTestDriver(akka.actor.ActorSystem system,
                                  PersistentEntity<C,E,S> entity,
                                  String entityId)

Method Detail

run

public PersistentEntityTestDriver.Outcome<E,S> run(Object... commands)

The entity will process the commands and the emitted events and side effects are recorded and provided in the returned Outcome. Current state is also included in the Outcome.

run may be invoked multiple times to divide the sequence of commands into manageable steps. The Outcome contains the events and side-effects of the last run, but the state is not reset between different runs.

run

public PersistentEntityTestDriver.Outcome<E,S> run(scala.collection.Seq<C> commands)

The entity will process the commands and the emitted events and side effects are recorded and provided in the returned Outcome. Current state is also included in the Outcome.

run may be invoked multiple times to divide the sequence of commands into manageable steps. The Outcome contains the events and side-effects of the last run, but the state is not reset between different runs.

getAllIssues

public java.util.List<PersistentEntityTestDriver.Issue> getAllIssues()

Accumulated issues from all previous runs.