public class DurableStore
extends java.lang.Object
Replicator
has to implement the protocol with the messages defined here.
At startup the Replicator
creates the durable store actor and sends the
Load
message to it. It must then reply with 0 or more LoadData
messages
followed by one LoadAllCompleted
message to the sender
(the Replicator
).
If the LoadAll
fails it can throw LoadFailed
and the Replicator
supervisor
will stop itself and the durable store.
When the Replicator
needs to store a value it sends a Store
message
to the durable store actor, which must then reply with the successMsg
or
failureMsg
to the replyTo
.
Modifier and Type | Class and Description |
---|---|
static class |
DurableStore.DurableDataEnvelope
Wrapper class for serialization of a data value.
|
static class |
DurableStore.LoadAll$
Request to load all entries.
|
static class |
DurableStore.LoadAllCompleted$ |
static class |
DurableStore.LoadData |
static class |
DurableStore.LoadData$ |
static class |
DurableStore.LoadFailed |
static class |
DurableStore.Store
Request to store an entry.
|
static class |
DurableStore.Store$ |
static class |
DurableStore.StoreReply |
static class |
DurableStore.StoreReply$ |
Constructor and Description |
---|
DurableStore() |