Package akka.cluster.ddata.typed.javadsl
Class Replicator$
- java.lang.Object
-
- akka.cluster.ddata.typed.javadsl.Replicator$
-
public class Replicator$ extends java.lang.Object
-
-
Field Summary
Fields Modifier and Type Field Description static Replicator$
MODULE$
Static reference to the singleton instance of this Scala object.
-
Constructor Summary
Constructors Constructor Description Replicator$()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Behavior<Replicator.Command>
behavior(ReplicatorSettings settings)
TheBehavior
for theReplicator
actor.Behavior<Replicator.Command>
behavior(ReplicatorSettings settings, ActorRef underlyingReplicator)
TheBehavior
for theReplicator
actor.Replicator.Command
flushChanges()
TheFlushChanges
instance.Replicator.ReadConsistency
readLocal()
TheReadLocal
instanceReplicator.WriteConsistency
writeLocal()
TheWriteLocal
instance
-
-
-
Field Detail
-
MODULE$
public static final Replicator$ MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Method Detail
-
behavior
public Behavior<Replicator.Command> behavior(ReplicatorSettings settings)
TheBehavior
for theReplicator
actor.
-
behavior
public Behavior<Replicator.Command> behavior(ReplicatorSettings settings, ActorRef underlyingReplicator)
-
readLocal
public Replicator.ReadConsistency readLocal()
TheReadLocal
instance
-
writeLocal
public Replicator.WriteConsistency writeLocal()
TheWriteLocal
instance
-
flushChanges
public Replicator.Command flushChanges()
TheFlushChanges
instance. Notify subscribers of changes now, otherwise they will be notified periodically with the configurednotify-subscribers-interval
.
-
-