org.eligosource.eventsourced.core
Instructs a Journal
to initiate message delivery for channels
.
Instructs a Journal
to batch-replay input messages to multiple Eventsourced
processors.
Instructs a Journal
to delete an output message that has been previously written by a
ReliableChannel
.
Instructs a Journal
to forward msg
to target
wrapped in a
org.eligosource.eventsourced.core.JournalProtocol.Looped message.
Message wrapper used by the org.eligosource.eventsourced.core.JournalProtocol.Loop command.
Instructs a Journal
to replay input messages to a single Eventsourced
processor.
Instructs a Journal
to replay output messages for a single ReliableChannel
.
Instructs a journal to request a state snapshot from a processor identified by
processorId
.
Instructs a journal to save the provided snapshot
.
Event received by journal when a snapshot has been successfully saved.
Event received by journal when a snapshot could not be successfully saved.
Instructs a Journal
to write an acknowledgement.
Instructs a Journal
to write an input message
.
Instructs a Journal
to write an output message
.
Message sent to targets after processing org.eligosource.eventsourced.core.JournalProtocol.WriteInMsg, org.eligosource.eventsourced.core.JournalProtocol.WriteOutMsg, org.eligosource.eventsourced.core.JournalProtocol.BatchReplayInMsgs, org.eligosource.eventsourced.core.JournalProtocol.ReplayInMsgs and org.eligosource.eventsourced.core.JournalProtocol.ReplayOutMsgs commands.
Response from a journal when message delivery by channels has been initiated.
Response from a journal to a sender when input message replay has been completed.
Defines message types that can be processed by a journal actor.