akka.persistence.multidc.testkit

Class PersistenceMultiDcTestKit

java.lang.Object

akka.persistence.multidc.testkit.PersistenceMultiDcTestKit

public class PersistenceMultiDcTestKit
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
PersistenceMultiDcTestKit()

Method Summary

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)

Methods inherited from class java.lang.Object

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

Constructor Detail

PersistenceMultiDcTestKit

public PersistenceMultiDcTestKit()

Method Detail

persistenceMultiDcTestSettings

public static com.typesafe.config.Config persistenceMultiDcTestSettings(java.lang.String name,
                                                                        java.lang.String dc,
                                                                        scala.collection.Seq<java.lang.String> allDcs)

disableReplication

public static void disableReplication(java.lang.String from,
                                      akka.actor.ActorSystem to)

disableReplication

public static void disableReplication(akka.actor.ActorSystem from,
                                      akka.actor.ActorSystem to)

enableReplication

public static void enableReplication(java.lang.String from,
                                     akka.actor.ActorSystem to)

enableReplication

public static void enableReplication(akka.actor.ActorSystem from,
                                     akka.actor.ActorSystem to)

enableAllReplicationTo

public static void enableAllReplicationTo(akka.actor.ActorSystem to)

addErrorFilter

public static void addErrorFilter(akka.actor.ActorSystem sys,
                                  java.lang.String key,
                                  scala.Function1<ReplicatedEventEnvelope,scala.Option<java.lang.Throwable>> f)

removeErrorFilter

public static void removeErrorFilter(akka.actor.ActorSystem sys,
                                     java.lang.String key)