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