Package org.apache.pekko.cluster.ddata.typed.javadsl

Class Replicator$

java.lang.Object

org.apache.pekko.cluster.ddata.typed.javadsl.Replicator$

public class Replicator$
extends Object

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
Replicator$()

Method Summary

Modifier and Type	Method	Description
Behavior<Replicator.Command>	behavior(ReplicatorSettings settings)	The Behavior for the Replicator actor.
Behavior<Replicator.Command>	behavior(ReplicatorSettings settings, ActorRef underlyingReplicator)	The Behavior for the Replicator actor.
Replicator.Command	flushChanges()	The FlushChanges instance.
Replicator.ReadConsistency	readLocal()	The ReadLocal instance
Replicator.WriteConsistency	writeLocal()	The WriteLocal instance

Methods inherited from class java.lang.Object

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

Field Details

MODULE$

public static final Replicator$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

Replicator$

public Replicator$()

Method Details

behavior

public Behavior<Replicator.Command> behavior(ReplicatorSettings settings)

The Behavior for the Replicator actor.

behavior

public Behavior<Replicator.Command> behavior(ReplicatorSettings settings,
 ActorRef underlyingReplicator)

The Behavior for the Replicator actor. It will use the given underlying pekko.cluster.ddata.Replicator

readLocal

public Replicator.ReadConsistency readLocal()

The ReadLocal instance

writeLocal

public Replicator.WriteConsistency writeLocal()

The WriteLocal instance

flushChanges

public Replicator.Command flushChanges()

The FlushChanges instance. Notify subscribers of changes now, otherwise they will be notified periodically with the configured notify-subscribers-interval.