Package org.apache.pekko.cluster.ddata.typed.scaladsl
package org.apache.pekko.cluster.ddata.typed.scaladsl
-
ClassDescriptionPekko extension for convenient configuration and use of the
Replicator.The data value is retrieved withpekko.cluster.ddata.Replicator.Changed.getusing the typed key.Replicator.Delete<A extends ReplicatedData>Notify subscribers of changes now, otherwise they will be notified periodically with the configurednotify-subscribers-interval.Replicator.Get<A extends ReplicatedData>Replicator.Subscribe<A extends ReplicatedData>Register a subscriber that will be notified with aChangedmessage when the value of the givenkeyis changed.Replicator.Unsubscribe<A extends ReplicatedData>Unregister a subscriber.Replicator.Update<A extends ReplicatedData>ReplicatorMessageAdapter<A,B extends ReplicatedData> When interacting with theReplicatorfrom an actor this class provides convenient methods that adapts the response messages to the requesting actor's message protocol.