Class WriteAggregator

    • Constructor Detail

      • WriteAggregator

        public WriteAggregator​(Key<ReplicatedData> key,
                               akka.cluster.ddata.Replicator.Internal.DataEnvelope envelope,
                               scala.Option<akka.cluster.ddata.Replicator.Internal.Delta> delta,
                               Replicator.WriteConsistency consistency,
                               scala.Option<java.lang.Object> req,
                               UniqueAddress selfUniqueAddress,
                               scala.collection.immutable.Vector<UniqueAddress> nodes,
                               scala.collection.immutable.Set<UniqueAddress> unreachable,
                               boolean shuffle,
                               ActorRef replyTo,
                               boolean durable)
    • Method Detail

      • writeMsg

        public akka.cluster.ddata.Replicator.Internal.Write writeMsg()
      • deltaMsg

        public scala.Option<akka.cluster.ddata.Replicator.Internal.DeltaPropagation> deltaMsg()
      • gotLocalStoreReply

        public boolean gotLocalStoreReply()
      • gotLocalStoreReply_$eq

        public void gotLocalStoreReply_$eq​(boolean x$1)
      • gotWriteNackFrom

        public scala.collection.immutable.Set<Address> gotWriteNackFrom()
      • gotWriteNackFrom_$eq

        public void gotWriteNackFrom_$eq​(scala.collection.immutable.Set<Address> x$1)
      • preStart

        public void preStart()
        Description copied from interface: Actor
        User overridable callback.

        Is called when an Actor is started. Actors are automatically started asynchronously when created. Empty default implementation.
        Specified by:
        preStart in interface Actor
      • receive

        public scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> receive()
        Description copied from interface: Actor
        Scala API: This defines the initial actor behavior, it must return a partial function with the actor logic.
        Specified by:
        receive in interface Actor
      • senderAddress

        public Address senderAddress()
      • isDone

        public boolean isDone()
      • notEnoughNodes

        public boolean notEnoughNodes()
      • reply

        public void reply​(boolean isTimeout)