akka.persistence.multidc

Class PersistenceMultiDcSettings

java.lang.Object

akka.persistence.multidc.PersistenceMultiDcSettings

public final class PersistenceMultiDcSettings
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description

PersistenceMultiDcSettings(scala.collection.immutable.Seq<java.lang.String> allDcs, java.lang.String journalPluginId, java.lang.String replicatedEventsQueryJournalPluginId, boolean useSpeculativeReplication, boolean useCrossReadingReplication, scala.concurrent.duration.FiniteDuration replicationRestartMinBackoff, scala.concurrent.duration.FiniteDuration replicationRestartMaxBackoff, int snapshotAfter, scala.concurrent.duration.Duration autoPassivateAfter, HotStandbySettings hotStandbySettings, ReplicatedEntityLoggingSettings loggingSettings)

Method Summary

Modifier and Type	Method and Description
scala.collection.immutable.Seq<java.lang.String>	allDcs()
static PersistenceMultiDcSettings	apply(akka.actor.ActorSystem system) Scala API
static PersistenceMultiDcSettings	apply(com.typesafe.config.Config config) Scala API
scala.concurrent.duration.Duration	autoPassivateAfter()
static PersistenceMultiDcSettings	create(akka.actor.ActorSystem system) Java API
static PersistenceMultiDcSettings	create(com.typesafe.config.Config config) Java API
static java.lang.String	DefaultReplicatedEventsQueryJournalPluginId() Use this identifier when constructing a Persistence Query stream to consume events of Replicated Entities
java.util.List<java.lang.String>	getAllDcs()
java.util.List<java.lang.String>	getOtherDcs(java.lang.String selfDc)
HotStandbySettings	hotStandbySettings()
java.lang.String	journalPluginId()
ReplicatedEntityLoggingSettings	loggingSettings()
scala.collection.immutable.Seq<java.lang.String>	otherDcs(java.lang.String selfDc)
java.lang.String	replicatedEventsQueryJournalPluginId()
scala.concurrent.duration.FiniteDuration	replicationRestartMaxBackoff()
scala.concurrent.duration.FiniteDuration	replicationRestartMinBackoff()
int	snapshotAfter()
java.lang.String	toString()
boolean	useCrossReadingReplication()
boolean	useSpeculativeReplication()
PersistenceMultiDcSettings	withAllDcs(scala.collection.immutable.Seq<java.lang.String> allDcs)
PersistenceMultiDcSettings	withAutoPassivateAfter(scala.concurrent.duration.Duration newSetting)
PersistenceMultiDcSettings	withCrossReadingReplication(boolean newUseCrossReadingRelication)
PersistenceMultiDcSettings	withHotStandbySettings(HotStandbySettings newSettings)
PersistenceMultiDcSettings	withJournalPluginId(java.lang.String journalPluginId)
PersistenceMultiDcSettings	withLoggingSettings(ReplicatedEntityLoggingSettings newSettings)
PersistenceMultiDcSettings	withReplicatedEventsQueryJournalPluginId(java.lang.String replicatedEventsQueryJournalPluginId)
PersistenceMultiDcSettings	withReplicationRestartBackoff(scala.concurrent.duration.FiniteDuration min, scala.concurrent.duration.FiniteDuration max)
PersistenceMultiDcSettings	withSnapshotAfter(int newSnapshotAfter)
PersistenceMultiDcSettings	withUseSpeculativeReplication(boolean newUseSpeculativeReplication)

Methods inherited from class java.lang.Object

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

Constructor Detail

PersistenceMultiDcSettings

public PersistenceMultiDcSettings(scala.collection.immutable.Seq<java.lang.String> allDcs,
                                  java.lang.String journalPluginId,
                                  java.lang.String replicatedEventsQueryJournalPluginId,
                                  boolean useSpeculativeReplication,
                                  boolean useCrossReadingReplication,
                                  scala.concurrent.duration.FiniteDuration replicationRestartMinBackoff,
                                  scala.concurrent.duration.FiniteDuration replicationRestartMaxBackoff,
                                  int snapshotAfter,
                                  scala.concurrent.duration.Duration autoPassivateAfter,
                                  HotStandbySettings hotStandbySettings,
                                  ReplicatedEntityLoggingSettings loggingSettings)

Method Detail

DefaultReplicatedEventsQueryJournalPluginId

public static java.lang.String DefaultReplicatedEventsQueryJournalPluginId()

Use this identifier when constructing a Persistence Query stream to consume events of Replicated Entities

The value is "cassandra-query-journal-multi-dc" and corresponds to the absolute path to the read journal configuration entry.

Returns:

(undocumented)

create

public static PersistenceMultiDcSettings create(akka.actor.ActorSystem system)

Java API

create

public static PersistenceMultiDcSettings create(com.typesafe.config.Config config)

Java API

apply

public static PersistenceMultiDcSettings apply(akka.actor.ActorSystem system)

Scala API

apply

public static PersistenceMultiDcSettings apply(com.typesafe.config.Config config)

Scala API

allDcs

public scala.collection.immutable.Seq<java.lang.String> allDcs()

journalPluginId

public java.lang.String journalPluginId()

replicatedEventsQueryJournalPluginId

public java.lang.String replicatedEventsQueryJournalPluginId()

useSpeculativeReplication

public boolean useSpeculativeReplication()

useCrossReadingReplication

public boolean useCrossReadingReplication()

replicationRestartMinBackoff

public scala.concurrent.duration.FiniteDuration replicationRestartMinBackoff()

replicationRestartMaxBackoff

public scala.concurrent.duration.FiniteDuration replicationRestartMaxBackoff()

snapshotAfter

public int snapshotAfter()

autoPassivateAfter

public scala.concurrent.duration.Duration autoPassivateAfter()

hotStandbySettings

public HotStandbySettings hotStandbySettings()

loggingSettings

public ReplicatedEntityLoggingSettings loggingSettings()

withAllDcs

public PersistenceMultiDcSettings withAllDcs(scala.collection.immutable.Seq<java.lang.String> allDcs)

withJournalPluginId

public PersistenceMultiDcSettings withJournalPluginId(java.lang.String journalPluginId)

withReplicatedEventsQueryJournalPluginId

public PersistenceMultiDcSettings withReplicatedEventsQueryJournalPluginId(java.lang.String replicatedEventsQueryJournalPluginId)

withUseSpeculativeReplication

public PersistenceMultiDcSettings withUseSpeculativeReplication(boolean newUseSpeculativeReplication)

withCrossReadingReplication

public PersistenceMultiDcSettings withCrossReadingReplication(boolean newUseCrossReadingRelication)

withReplicationRestartBackoff

public PersistenceMultiDcSettings withReplicationRestartBackoff(scala.concurrent.duration.FiniteDuration min,
                                                                scala.concurrent.duration.FiniteDuration max)

withSnapshotAfter

public PersistenceMultiDcSettings withSnapshotAfter(int newSnapshotAfter)

withHotStandbySettings

public PersistenceMultiDcSettings withHotStandbySettings(HotStandbySettings newSettings)

withAutoPassivateAfter

public PersistenceMultiDcSettings withAutoPassivateAfter(scala.concurrent.duration.Duration newSetting)

withLoggingSettings

public PersistenceMultiDcSettings withLoggingSettings(ReplicatedEntityLoggingSettings newSettings)

otherDcs

public scala.collection.immutable.Seq<java.lang.String> otherDcs(java.lang.String selfDc)

getAllDcs

public java.util.List<java.lang.String> getAllDcs()

getOtherDcs

public java.util.List<java.lang.String> getOtherDcs(java.lang.String selfDc)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object