akka.cluster.ddata

Class Replicator.StoreFailure<A extends ReplicatedData>

java.lang.Object

akka.cluster.ddata.Replicator.UpdateResponse<A>

akka.cluster.ddata.Replicator.UpdateFailure<A>

akka.cluster.ddata.Replicator.StoreFailure<A>

All Implemented Interfaces:

NoSerializationVerificationNeeded, Replicator.DeleteResponse<A>, java.io.Serializable, scala.Equals, scala.Product

Enclosing class:

Replicator

public static final class Replicator.StoreFailure<A extends ReplicatedData>
extends Replicator.UpdateFailure<A>
implements Replicator.DeleteResponse<A>, scala.Product, scala.Serializable

The local store or direct replication of the Replicator.Update could not be fulfill according to the given consistency level due to durable store errors. This is only used for entries that have been configured to be durable.

The Update was still performed in memory locally and possibly replicated to some nodes, but it might not have been written to durable storage. It will eventually be disseminated to other replicas, unless the local replica crashes before it has been able to communicate with other replicas.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
StoreFailure(Key<A> key, scala.Option<java.lang.Object> request)

Method Summary

Modifier and Type	Method and Description
Key<A>	key()
scala.Option<java.lang.Object>	request()

Methods inherited from class akka.cluster.ddata.Replicator.UpdateResponse

getRequest

Methods inherited from class java.lang.Object

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

Methods inherited from interface scala.Product

$init$, productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

StoreFailure

public StoreFailure(Key<A> key,
                    scala.Option<java.lang.Object> request)

Method Detail

key

public Key<A> key()

Specified by:

key in interface Replicator.DeleteResponse<A extends ReplicatedData>

Specified by:

key in class Replicator.UpdateResponse<A extends ReplicatedData>

request

public scala.Option<java.lang.Object> request()

Specified by:

request in class Replicator.UpdateResponse<A extends ReplicatedData>