public class DurableStore extends java.lang.ObjectAn actor implementing the durable store for the Distributed Data
Replicatorhas to implement the protocol with the messages defined here.
At startup the
Replicatorcreates the durable store actor and sends the
Loadmessage to it. It must then reply with 0 or more
LoadDatamessages followed by one
LoadAllCompletedmessage to the
LoadAllfails it can throw
Replicatorsupervisor will stop itself and the durable store.
Replicatorneeds to store a value it sends a
Storemessage to the durable store actor, which must then reply with the
When entries have expired the
Expiremessage to the durable store actor, which can delete the entries from the backend store.
Nested Class Summary
Nested Classes Modifier and Type Class Description
DurableStore.DurableDataEnvelopeWrapper class for serialization of a data value.
DurableStore.ExpireRequest to expire (remove) entries.
DurableStore.LoadAll$Request to load all entries.
DurableStore.StoreRequest to store an entry.
Constructors Constructor Description