Package org.apache.pekko.persistence

Class JournalProtocol

java.lang.Object

org.apache.pekko.persistence.JournalProtocol

public class JournalProtocol
extends Object

INTERNAL API.

Messages exchanged between persistent actors and a journal.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	JournalProtocol.DeleteMessagesTo	Request to delete all persistent messages with sequence numbers up to toSequenceNr (inclusive).
static class	JournalProtocol.DeleteMessagesTo$
static final class	JournalProtocol.LoopMessageSuccess	Reply message to a JournalProtocol.WriteMessages with a non-persistent message.
static class	JournalProtocol.LoopMessageSuccess$
static interface	JournalProtocol.Message	Marker trait shared by internal journal messages.
static class	JournalProtocol.RecoverySuccess	Reply message to a successful JournalProtocol.ReplayMessages request.
static class	JournalProtocol.RecoverySuccess$
static final class	JournalProtocol.ReplayBatchAck	Acknowledges that the requester has processed the replayed messages emitted before the corresponding JournalProtocol.ReplayBatchReady.
static class	JournalProtocol.ReplayBatchAck$
static final class	JournalProtocol.ReplayBatchCancel	Cancels a bounded replay after its replay filter has failed.
static class	JournalProtocol.ReplayBatchCancel$
static final class	JournalProtocol.ReplayBatchReady	Signals that one bounded replay batch has been emitted.
static class	JournalProtocol.ReplayBatchReady$
static final class	JournalProtocol.ReplayBatchResponse	Associates a bounded replay response with the recovering actor incarnation that requested it.
static class	JournalProtocol.ReplayBatchResponse$
static final class	JournalProtocol.ReplayedMessage	Reply message to a JournalProtocol.ReplayMessages request.
static class	JournalProtocol.ReplayedMessage$
static final class	JournalProtocol.ReplayMessages	Request to replay messages to persistentActor.
static class	JournalProtocol.ReplayMessages$
static class	JournalProtocol.ReplayMessagesCancel$	Cancels all bounded replays requested by the sender.
static final class	JournalProtocol.ReplayMessagesFailure	Reply message to a failed JournalProtocol.ReplayMessages request.
static class	JournalProtocol.ReplayMessagesFailure$
static final class	JournalProtocol.ReplayMessagesWithBatching	Opts the sender in to bounded replay for the immediately following JournalProtocol.ReplayMessages request.
static class	JournalProtocol.ReplayMessagesWithBatching$
static interface	JournalProtocol.Request	Internal journal command.
static interface	JournalProtocol.Response	Internal journal acknowledgement.
static final class	JournalProtocol.WriteMessageFailure	Reply message to a failed JournalProtocol.WriteMessages request.
static class	JournalProtocol.WriteMessageFailure$
static final class	JournalProtocol.WriteMessageRejected	Reply message to a rejected JournalProtocol.WriteMessages request.
static class	JournalProtocol.WriteMessageRejected$
static final class	JournalProtocol.WriteMessages	Request to write messages.
static class	JournalProtocol.WriteMessages$
static final class	JournalProtocol.WriteMessagesFailed	Reply message to a failed JournalProtocol.WriteMessages request.
static class	JournalProtocol.WriteMessagesFailed$
static class	JournalProtocol.WriteMessagesSuccessful$	Reply message to a successful JournalProtocol.WriteMessages request.
static final class	JournalProtocol.WriteMessageSuccess	Reply message to a successful JournalProtocol.WriteMessages request.
static class	JournalProtocol.WriteMessageSuccess$

Constructor Summary

Constructors

Constructor	Description
JournalProtocol()

Method Summary

Methods inherited from class java.lang.Object

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

Constructor Details

JournalProtocol

public JournalProtocol()