akka.persistence.multidc.testkit

Class Simulator<Command,Event,State>

java.lang.Object

akka.persistence.multidc.testkit.Simulator<Command,Event,State>

public class Simulator<Command,Event,State>
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
Simulator(scala.Function0<InternalReplicatedEntity<Command,Event,State>> entityCtor, akka.actor.ActorSystem system, java.lang.String selfDc, scala.collection.immutable.Set<java.lang.String> allDcs, scala.Option<java.lang.String> dispatcherId)

Method Summary

Modifier and Type	Method and Description
static <C,E,S> Simulator<C,E,S>	apply(scala.Function0<ReplicatedEntity<C,E,S>> entity, akka.actor.ActorSystem system, java.lang.String selfDc, scala.collection.immutable.Set<java.lang.String> allDcs, scala.Option<java.lang.String> dispatcherId)
static <C,E,S> scala.Option<java.lang.String>	apply$default$5()
void	clearResponses()
static <C,E,S> Simulator<C,E,S>	create(java.util.function.Supplier<ReplicatedEntity<C,E,S>> entity, akka.actor.ActorSystem system, java.lang.String selfDc, java.util.Set<java.lang.String> allDcs, java.util.Optional<java.lang.String> dispatcherId) Java API
static <C,E,S> java.util.Optional<java.lang.String>	create$default$5()
scala.collection.immutable.IndexedSeq<Event>	events()
java.util.List<Event>	getEvents()
java.util.List<java.lang.Object>	getResponses() Java API
java.util.List<java.lang.Object>	getSelfMessages() Java API
boolean	isTimerActive(java.lang.Object key)
java.lang.String	otherDc()
scala.collection.immutable.IndexedSeq<java.lang.Object>	parentMessages()
void	replicatedEvent(Event event)
void	replicatedEvent(Event event, long timestamp, java.lang.String dc, boolean concurrent)
scala.collection.immutable.IndexedSeq<java.lang.Object>	responses()
void	restart()
void	runCommand(Command command)
void	runCommand(java.lang.Object... commands) Java API
void	runCommand(scala.collection.Seq<Command> commands)
scala.collection.immutable.IndexedSeq<java.lang.Object>	selfMessages()
scala.Option<State>	snapshot()
State	state()
boolean	stopped()
akka.actor.ActorSystem	system()
void	takeSnapshot()
void	triggerReceiveTimeout()
void	triggerTimer(java.lang.Object key)

Methods inherited from class java.lang.Object

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

Constructor Detail

Simulator

public Simulator(scala.Function0<InternalReplicatedEntity<Command,Event,State>> entityCtor,
                 akka.actor.ActorSystem system,
                 java.lang.String selfDc,
                 scala.collection.immutable.Set<java.lang.String> allDcs,
                 scala.Option<java.lang.String> dispatcherId)

Method Detail

apply

public static <C,E,S> Simulator<C,E,S> apply(scala.Function0<ReplicatedEntity<C,E,S>> entity,
                                             akka.actor.ActorSystem system,
                                             java.lang.String selfDc,
                                             scala.collection.immutable.Set<java.lang.String> allDcs,
                                             scala.Option<java.lang.String> dispatcherId)

Parameters:

dispatcherId - You may use akka.testkit.CallingThreadDispatcher.Id here for now when testing an actor that uses pipeTo, to make sure messages are delivered before collecting side effects and continuing the test. Better might be to use an asynchronous dispatcher which can be inspected to make sure all pending tasks have completed before continuing, but no such dispatcher is provided at this time.

entity - (undocumented)

system - (undocumented)

selfDc - (undocumented)

allDcs - (undocumented)

Returns:

(undocumented)

apply$default$5

public static <C,E,S> scala.Option<java.lang.String> apply$default$5()

create

public static <C,E,S> Simulator<C,E,S> create(java.util.function.Supplier<ReplicatedEntity<C,E,S>> entity,
                                              akka.actor.ActorSystem system,
                                              java.lang.String selfDc,
                                              java.util.Set<java.lang.String> allDcs,
                                              java.util.Optional<java.lang.String> dispatcherId)

Java API

Parameters:

entity - (undocumented)

system - (undocumented)

selfDc - (undocumented)

allDcs - (undocumented)

dispatcherId - (undocumented)

Returns:

(undocumented)

create$default$5

public static <C,E,S> java.util.Optional<java.lang.String> create$default$5()

runCommand

public void runCommand(java.lang.Object... commands)

Java API

system

public akka.actor.ActorSystem system()

otherDc

public java.lang.String otherDc()

state

public State state()

snapshot

public scala.Option<State> snapshot()

stopped

public boolean stopped()

events

public scala.collection.immutable.IndexedSeq<Event> events()

getEvents

public java.util.List<Event> getEvents()

selfMessages

public scala.collection.immutable.IndexedSeq<java.lang.Object> selfMessages()

getSelfMessages

public java.util.List<java.lang.Object> getSelfMessages()

Java API

responses

public scala.collection.immutable.IndexedSeq<java.lang.Object> responses()

getResponses

public java.util.List<java.lang.Object> getResponses()

Java API

clearResponses

public void clearResponses()

parentMessages

public scala.collection.immutable.IndexedSeq<java.lang.Object> parentMessages()

runCommand

public void runCommand(Command command)

runCommand

public void runCommand(scala.collection.Seq<Command> commands)

triggerReceiveTimeout

public void triggerReceiveTimeout()

replicatedEvent

public void replicatedEvent(Event event)

replicatedEvent

public void replicatedEvent(Event event,
                            long timestamp,
                            java.lang.String dc,
                            boolean concurrent)

restart

public void restart()

takeSnapshot

public void takeSnapshot()

isTimerActive

public boolean isTimerActive(java.lang.Object key)

triggerTimer

public void triggerTimer(java.lang.Object key)