public class PersistenceMultiDcTestKit$
extends java.lang.Object
| Modifier and Type | Field and Description |
|---|---|
static PersistenceMultiDcTestKit$ |
MODULE$
Static reference to the singleton instance of this Scala object.
|
| Constructor and Description |
|---|
PersistenceMultiDcTestKit$() |
| Modifier and Type | Method and Description |
|---|---|
void |
addErrorFilter(akka.actor.ActorSystem sys,
java.lang.String key,
scala.Function1<ReplicatedEventEnvelope,scala.Option<java.lang.Throwable>> f) |
void |
disableReplication(akka.actor.ActorSystem from,
akka.actor.ActorSystem to) |
void |
disableReplication(java.lang.String from,
akka.actor.ActorSystem to) |
void |
enableAllReplicationTo(akka.actor.ActorSystem to) |
void |
enableReplication(akka.actor.ActorSystem from,
akka.actor.ActorSystem to) |
void |
enableReplication(java.lang.String from,
akka.actor.ActorSystem to) |
com.typesafe.config.Config |
persistenceMultiDcTestSettings(java.lang.String name,
java.lang.String dc,
scala.collection.Seq<java.lang.String> allDcs) |
void |
removeErrorFilter(akka.actor.ActorSystem sys,
java.lang.String key) |
public static final PersistenceMultiDcTestKit$ MODULE$
public com.typesafe.config.Config persistenceMultiDcTestSettings(java.lang.String name,
java.lang.String dc,
scala.collection.Seq<java.lang.String> allDcs)
public void disableReplication(java.lang.String from,
akka.actor.ActorSystem to)
public void disableReplication(akka.actor.ActorSystem from,
akka.actor.ActorSystem to)
public void enableReplication(java.lang.String from,
akka.actor.ActorSystem to)
public void enableReplication(akka.actor.ActorSystem from,
akka.actor.ActorSystem to)
public void enableAllReplicationTo(akka.actor.ActorSystem to)
public void addErrorFilter(akka.actor.ActorSystem sys,
java.lang.String key,
scala.Function1<ReplicatedEventEnvelope,scala.Option<java.lang.Throwable>> f)
public void removeErrorFilter(akka.actor.ActorSystem sys,
java.lang.String key)