akka.persistence.multidc.testkit

Class PersistenceMultiDcTestKit$

java.lang.Object

akka.persistence.multidc.testkit.PersistenceMultiDcTestKit$

public class PersistenceMultiDcTestKit$
extends java.lang.Object

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
PersistenceMultiDcTestKit$()

Method Summary

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)

Methods inherited from class java.lang.Object

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

Field Detail

MODULE$

public static final PersistenceMultiDcTestKit$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

PersistenceMultiDcTestKit$

public PersistenceMultiDcTestKit$()

Method Detail

persistenceMultiDcTestSettings

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

disableReplication

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

disableReplication

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

enableReplication

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

enableReplication

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

enableAllReplicationTo

public void enableAllReplicationTo(akka.actor.ActorSystem to)

addErrorFilter

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

removeErrorFilter

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