akka.persistence.multidc.testkit

Class Simulator$

java.lang.Object

akka.persistence.multidc.testkit.Simulator$

public class Simulator$
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
static Simulator$	MODULE$ Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor and Description
Simulator$()

Method Summary

Modifier and Type	Method and Description
<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)
<C,E,S> scala.Option<java.lang.String>	apply$default$5()
<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
<C,E,S> java.util.Optional<java.lang.String>	create$default$5()

Methods inherited from class java.lang.Object

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

Field Detail

MODULE$

public static final Simulator$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

Simulator$

public Simulator$()

Method Detail

apply

public <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 <C,E,S> scala.Option<java.lang.String> apply$default$5()

create

public <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 <C,E,S> java.util.Optional<java.lang.String> create$default$5()