- AbstractPersistentActor - Class in akka.persistence
-
Java API: an persistent actor - can be used to implement command or event sourcing.
- AbstractPersistentActor() - Constructor for class akka.persistence.AbstractPersistentActor
-
- AbstractPersistentActorWithAtLeastOnceDelivery - Class in akka.persistence
-
Java API compatible with lambda expressions
- AbstractPersistentActorWithAtLeastOnceDelivery() - Constructor for class akka.persistence.AbstractPersistentActorWithAtLeastOnceDelivery
-
- AbstractPersistentFSM<S extends PersistentFSM.FSMState,D,E> - Class in akka.persistence.fsm
-
Java API: compatible with lambda expressions
- AbstractPersistentFSM() - Constructor for class akka.persistence.fsm.AbstractPersistentFSM
-
- AbstractPersistentFSMBase<S,D,E> - Class in akka.persistence.fsm
-
Java API: compatible with lambda expressions
- AbstractPersistentFSMBase() - Constructor for class akka.persistence.fsm.AbstractPersistentFSMBase
-
- AbstractPersistentFSMBase$ - Class in akka.persistence.fsm
-
Java API: compatible with lambda expressions
- AbstractPersistentFSMBase$() - Constructor for class akka.persistence.fsm.AbstractPersistentFSMBase$
-
- AbstractPersistentLoggingFSM<S extends PersistentFSM.FSMState,D,E> - Class in akka.persistence.fsm
-
Java API: compatible with lambda expressions
- AbstractPersistentLoggingFSM() - Constructor for class akka.persistence.fsm.AbstractPersistentLoggingFSM
-
- AbstractPersistentView - Class in akka.persistence
-
Java API: compatible with lambda expressions (to be used with ReceiveBuilder
)
- AbstractPersistentView() - Constructor for class akka.persistence.AbstractPersistentView
-
- actor() - Method in class akka.persistence.Persistence.PluginHolder
-
- actorInstanceId() - Method in class akka.persistence.JournalProtocol.LoopMessageSuccess
-
- actorInstanceId() - Method in class akka.persistence.JournalProtocol.WriteMessageFailure
-
- actorInstanceId() - Method in class akka.persistence.JournalProtocol.WriteMessageRejected
-
- actorInstanceId() - Method in class akka.persistence.JournalProtocol.WriteMessages
-
- actorInstanceId() - Method in class akka.persistence.JournalProtocol.WriteMessageSuccess
-
- actorRef() - Method in class akka.persistence.fsm.PersistentFSM.SubscribeTransitionCallBack
-
- actorRef() - Method in class akka.persistence.fsm.PersistentFSM.UnsubscribeTransitionCallBack
-
- adapters() - Method in class akka.persistence.journal.EventAdapters.CombinedReadEventAdapter
-
- adapters() - Method in class akka.persistence.Persistence.PluginHolder
-
- adaptersFor(String) - Method in class akka.persistence.Persistence
-
Returns an
EventAdapters
object which serves as a per-journal collection of bound event adapters.
- adaptersFor(ActorRef) - Method in class akka.persistence.Persistence
-
INTERNAL API
Looks up
EventAdapters
by journal plugin's ActorRef.
- adaptFromJournal(PersistentRepr) - Method in interface akka.persistence.journal.WriteJournalBase
-
INTERNAL API
- adaptToJournal(PersistentRepr) - Method in interface akka.persistence.journal.WriteJournalBase
-
INTERNAL API
- add(PersistentRepr) - Method in interface akka.persistence.journal.inmem.InmemMessages
-
- addAllPayload(Iterable<? extends MessageFormats.PersistentMessage>) - Method in class akka.persistence.serialization.MessageFormats.AtomicWrite.Builder
-
repeated .PersistentMessage payload = 1;
- addAllPersistenceIdsSubscriber(ActorRef) - Method in interface akka.persistence.journal.leveldb.LeveldbStore
-
- addAllUnconfirmedDeliveries(Iterable<? extends MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery>) - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.Builder
-
repeated .AtLeastOnceDeliverySnapshot.UnconfirmedDelivery unconfirmedDeliveries = 2;
- addPayload(MessageFormats.PersistentMessage) - Method in class akka.persistence.serialization.MessageFormats.AtomicWrite.Builder
-
repeated .PersistentMessage payload = 1;
- addPayload(int, MessageFormats.PersistentMessage) - Method in class akka.persistence.serialization.MessageFormats.AtomicWrite.Builder
-
repeated .PersistentMessage payload = 1;
- addPayload(MessageFormats.PersistentMessage.Builder) - Method in class akka.persistence.serialization.MessageFormats.AtomicWrite.Builder
-
repeated .PersistentMessage payload = 1;
- addPayload(int, MessageFormats.PersistentMessage.Builder) - Method in class akka.persistence.serialization.MessageFormats.AtomicWrite.Builder
-
repeated .PersistentMessage payload = 1;
- addPayloadBuilder() - Method in class akka.persistence.serialization.MessageFormats.AtomicWrite.Builder
-
repeated .PersistentMessage payload = 1;
- addPayloadBuilder(int) - Method in class akka.persistence.serialization.MessageFormats.AtomicWrite.Builder
-
repeated .PersistentMessage payload = 1;
- addPersistenceIdSubscriber(ActorRef, String) - Method in interface akka.persistence.journal.leveldb.LeveldbStore
-
- addTagSubscriber(ActorRef, String) - Method in interface akka.persistence.journal.leveldb.LeveldbStore
-
- addToMessageBatch(PersistentRepr, Set<String>, org.iq80.leveldb.WriteBatch) - Method in interface akka.persistence.journal.leveldb.LeveldbStore
-
- addUnconfirmedDeliveries(MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery) - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.Builder
-
repeated .AtLeastOnceDeliverySnapshot.UnconfirmedDelivery unconfirmedDeliveries = 2;
- addUnconfirmedDeliveries(int, MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery) - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.Builder
-
repeated .AtLeastOnceDeliverySnapshot.UnconfirmedDelivery unconfirmedDeliveries = 2;
- addUnconfirmedDeliveries(MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery.Builder) - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.Builder
-
repeated .AtLeastOnceDeliverySnapshot.UnconfirmedDelivery unconfirmedDeliveries = 2;
- addUnconfirmedDeliveries(int, MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery.Builder) - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.Builder
-
repeated .AtLeastOnceDeliverySnapshot.UnconfirmedDelivery unconfirmedDeliveries = 2;
- addUnconfirmedDeliveriesBuilder() - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.Builder
-
repeated .AtLeastOnceDeliverySnapshot.UnconfirmedDelivery unconfirmedDeliveries = 2;
- addUnconfirmedDeliveriesBuilder(int) - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.Builder
-
repeated .AtLeastOnceDeliverySnapshot.UnconfirmedDelivery unconfirmedDeliveries = 2;
- advance() - Method in interface akka.persistence.fsm.LoggingPersistentFSM
-
- afterTransitionDo() - Method in class akka.persistence.fsm.PersistentFSM.State
-
- akka.persistence - package akka.persistence
-
- akka.persistence.fsm - package akka.persistence.fsm
-
- akka.persistence.fsm.japi.pf - package akka.persistence.fsm.japi.pf
-
- akka.persistence.journal - package akka.persistence.journal
-
- akka.persistence.journal.inmem - package akka.persistence.journal.inmem
-
- akka.persistence.journal.japi - package akka.persistence.journal.japi
-
- akka.persistence.journal.leveldb - package akka.persistence.journal.leveldb
-
- akka.persistence.serialization - package akka.persistence.serialization
-
- akka.persistence.snapshot - package akka.persistence.snapshot
-
- akka.persistence.snapshot.japi - package akka.persistence.snapshot.japi
-
- akka.persistence.snapshot.local - package akka.persistence.snapshot.local
-
- allPersistenceIds() - Method in interface akka.persistence.journal.leveldb.LeveldbIdMapping
-
- allPersistenceIds() - Method in class akka.persistence.journal.leveldb.LeveldbJournal.CurrentPersistenceIds
-
- allPersistenceIdsSubscribers() - Method in interface akka.persistence.journal.leveldb.LeveldbStore
-
- andThen(Function1<D, BoxedUnit>) - Method in class akka.persistence.fsm.PersistentFSM.State
-
Register a handler to be triggered after the state has been persisted successfully
- anyEvent(FI.Apply2<Object, D, PersistentFSM.State<S, D, E>>) - Method in class akka.persistence.fsm.japi.pf.FSMStateFunctionBuilder
-
Add a case statement that matches on any type of event.
- apply(PersistentRepr) - Method in class akka.persistence.AtomicWrite$
-
- apply(PersistentRepr) - Static method in class akka.persistence.AtomicWrite
-
- apply(Object) - Method in class akka.persistence.fsm.PersistentFSM.NullFunction$
-
- apply(ExtendedActorSystem, Config) - Method in class akka.persistence.journal.EventAdapters$
-
- apply(ExtendedActorSystem, Config) - Static method in class akka.persistence.journal.EventAdapters
-
- apply(Seq<Object>) - Method in class akka.persistence.journal.EventSeq$
-
- apply(Seq<Object>) - Static method in class akka.persistence.journal.EventSeq
-
- apply(Object, long, String, String, boolean, ActorRef, String) - Method in class akka.persistence.PersistentRepr$
-
Plugin API.
- applyEvent(E, D) - Method in interface akka.persistence.fsm.PersistentFSM
-
Override this handler to define the action on Domain Event
- applying(Object...) - Method in class akka.persistence.fsm.PersistentFSM.State
-
Specify domain events to be applied when transitioning to the new state.
- applying(Seq<E>) - Method in class akka.persistence.fsm.PersistentFSM.State
-
Specify domain events to be applied when transitioning to the new state.
- applyState(PersistentFSM.State<S, D, E>) - Method in interface akka.persistence.fsm.PersistentFSM
-
Persist FSM State and FSM State Data
- applyState(PersistentFSM.State<S, D, E>) - Method in interface akka.persistence.fsm.PersistentFSMBase
-
- aroundPostRestart(Throwable) - Method in interface akka.persistence.Eventsourced
-
INTERNAL API.
- aroundPostStop() - Method in interface akka.persistence.AtLeastOnceDeliveryLike
-
INTERNAL API
- aroundPostStop() - Method in interface akka.persistence.Eventsourced
-
INTERNAL API.
- aroundPreRestart(Throwable, Option<Object>) - Method in interface akka.persistence.AtLeastOnceDeliveryLike
-
INTERNAL API
- aroundPreRestart(Throwable, Option<Object>) - Method in interface akka.persistence.Eventsourced
-
INTERNAL API.
- aroundPreStart() - Method in interface akka.persistence.Eventsourced
-
INTERNAL API.
- aroundPreStart() - Method in interface akka.persistence.journal.AsyncWriteProxy
-
- aroundPreStart() - Method in interface akka.persistence.PersistentView
-
INTERNAL API.
- aroundReceive(PartialFunction<Object, BoxedUnit>, Object) - Method in interface akka.persistence.AtLeastOnceDeliveryLike
-
INTERNAL API
- aroundReceive(PartialFunction<Object, BoxedUnit>, Object) - Method in interface akka.persistence.Eventsourced
-
INTERNAL API.
- aroundReceive(PartialFunction<Object, BoxedUnit>, Object) - Method in interface akka.persistence.journal.AsyncWriteProxy
-
- aroundReceive(PartialFunction<Object, BoxedUnit>, Object) - Method in interface akka.persistence.PersistentView
-
INTERNAL API.
- asyncDeleteMessagesTo(String, long) - Method in interface akka.persistence.journal.AsyncWriteJournal
-
Plugin API: asynchronously deletes all persistent messages up to toSequenceNr
(inclusive).
- asyncDeleteMessagesTo(String, long) - Method in interface akka.persistence.journal.AsyncWriteProxy
-
- asyncDeleteMessagesTo(String, long) - Method in class akka.persistence.journal.japi.AsyncWriteJournal
-
- asyncDeleteMessagesTo(String, long) - Method in interface akka.persistence.journal.leveldb.LeveldbStore
-
- AsyncHandlerInvocation(Object, Function1<Object, BoxedUnit>) - Constructor for class akka.persistence.Eventsourced.AsyncHandlerInvocation
-
- AsyncHandlerInvocation$() - Constructor for class akka.persistence.Eventsourced.AsyncHandlerInvocation$
-
- asyncReadHighestSequenceNr(String, long) - Method in interface akka.persistence.journal.AsyncRecovery
-
Plugin API: asynchronously reads the highest stored sequence number for the
given persistenceId
.
- asyncReadHighestSequenceNr(String, long) - Method in interface akka.persistence.journal.AsyncWriteProxy
-
- asyncReadHighestSequenceNr(String, long) - Method in class akka.persistence.journal.japi.AsyncRecovery
-
- asyncReadHighestSequenceNr(String, long) - Method in interface akka.persistence.journal.leveldb.LeveldbRecovery
-
- AsyncRecovery - Interface in akka.persistence.journal
-
Asynchronous message replay and sequence number recovery interface.
- AsyncRecovery - Class in akka.persistence.journal.japi
-
Java API: asynchronous message replay and sequence number recovery interface.
- AsyncRecovery() - Constructor for class akka.persistence.journal.japi.AsyncRecovery
-
- asyncReplayMessages(String, long, long, long, Function1<PersistentRepr, BoxedUnit>) - Method in interface akka.persistence.journal.AsyncRecovery
-
Plugin API: asynchronously replays persistent messages.
- asyncReplayMessages(String, long, long, long, Function1<PersistentRepr, BoxedUnit>) - Method in interface akka.persistence.journal.AsyncWriteProxy
-
- asyncReplayMessages(String, long, long, long, Function1<PersistentRepr, BoxedUnit>) - Method in class akka.persistence.journal.japi.AsyncRecovery
-
- asyncReplayMessages(String, long, long, long, Function1<PersistentRepr, BoxedUnit>) - Method in interface akka.persistence.journal.leveldb.LeveldbRecovery
-
- asyncReplayTaggedMessages(String, long, long, long, Function1<LeveldbJournal.ReplayedTaggedMessage, BoxedUnit>) - Method in interface akka.persistence.journal.leveldb.LeveldbRecovery
-
- AsyncReplayTimeoutException - Exception in akka.persistence.journal
-
Thrown if replay inactivity exceeds a specified timeout.
- AsyncReplayTimeoutException(String) - Constructor for exception akka.persistence.journal.AsyncReplayTimeoutException
-
- AsyncWriteJournal - Interface in akka.persistence.journal
-
Abstract journal, optimized for asynchronous, non-blocking writes.
- AsyncWriteJournal - Class in akka.persistence.journal.japi
-
Java API: abstract journal, optimized for asynchronous, non-blocking writes.
- AsyncWriteJournal() - Constructor for class akka.persistence.journal.japi.AsyncWriteJournal
-
- AsyncWriteJournal$ - Class in akka.persistence.journal
-
INTERNAL API.
- AsyncWriteJournal$() - Constructor for class akka.persistence.journal.AsyncWriteJournal$
-
- AsyncWriteJournal.Desequenced - Class in akka.persistence.journal
-
- AsyncWriteJournal.Desequenced$ - Class in akka.persistence.journal
-
- AsyncWriteJournal.Resequencer - Class in akka.persistence.journal
-
- asyncWriteMessages(Seq<AtomicWrite>) - Method in interface akka.persistence.journal.AsyncWriteJournal
-
Plugin API: asynchronously writes a batch (Seq
) of persistent messages to the
journal.
- asyncWriteMessages(Seq<AtomicWrite>) - Method in interface akka.persistence.journal.AsyncWriteProxy
-
- asyncWriteMessages(Seq<AtomicWrite>) - Method in class akka.persistence.journal.japi.AsyncWriteJournal
-
- asyncWriteMessages(Seq<AtomicWrite>) - Method in interface akka.persistence.journal.leveldb.LeveldbStore
-
- AsyncWriteProxy - Interface in akka.persistence.journal
-
INTERNAL API.
- AsyncWriteProxy$ - Class in akka.persistence.journal
-
INTERNAL API.
- AsyncWriteProxy$() - Constructor for class akka.persistence.journal.AsyncWriteProxy$
-
- AsyncWriteProxy.InitTimeout$ - Class in akka.persistence.journal
-
- AsyncWriteProxy.SetStore - Class in akka.persistence.journal
-
- AsyncWriteProxy.SetStore$ - Class in akka.persistence.journal
-
- AsyncWriteTarget - Class in akka.persistence.journal
-
INTERNAL API.
- AsyncWriteTarget() - Constructor for class akka.persistence.journal.AsyncWriteTarget
-
- AsyncWriteTarget$ - Class in akka.persistence.journal
-
INTERNAL API.
- AsyncWriteTarget$() - Constructor for class akka.persistence.journal.AsyncWriteTarget$
-
- AsyncWriteTarget.DeleteMessagesTo - Class in akka.persistence.journal
-
- AsyncWriteTarget.DeleteMessagesTo$ - Class in akka.persistence.journal
-
- AsyncWriteTarget.ReplayFailure - Class in akka.persistence.journal
-
- AsyncWriteTarget.ReplayFailure$ - Class in akka.persistence.journal
-
- AsyncWriteTarget.ReplayMessages - Class in akka.persistence.journal
-
- AsyncWriteTarget.ReplayMessages$ - Class in akka.persistence.journal
-
- AsyncWriteTarget.ReplaySuccess - Class in akka.persistence.journal
-
- AsyncWriteTarget.ReplaySuccess$ - Class in akka.persistence.journal
-
- AsyncWriteTarget.WriteMessages - Class in akka.persistence.journal
-
- AsyncWriteTarget.WriteMessages$ - Class in akka.persistence.journal
-
- AtLeastOnceDelivery - Interface in akka.persistence
-
Mix-in this trait with your PersistentActor
to send messages with at-least-once
delivery semantics to destinations.
- atLeastOnceDelivery() - Method in class akka.persistence.PersistenceSettings
-
- atLeastOnceDelivery() - Constructor for class akka.persistence.PersistenceSettings.atLeastOnceDelivery
-
- AtLeastOnceDelivery$ - Class in akka.persistence
-
- AtLeastOnceDelivery$() - Constructor for class akka.persistence.AtLeastOnceDelivery$
-
- AtLeastOnceDelivery.AtLeastOnceDeliverySnapshot - Class in akka.persistence
-
Snapshot of current AtLeastOnceDelivery
state.
- AtLeastOnceDelivery.AtLeastOnceDeliverySnapshot$ - Class in akka.persistence
-
- AtLeastOnceDelivery.Internal$ - Class in akka.persistence
-
INTERNAL API
- AtLeastOnceDelivery.Internal$.Delivery - Class in akka.persistence
-
- AtLeastOnceDelivery.Internal$.RedeliveryTick - Class in akka.persistence
-
- AtLeastOnceDelivery.MaxUnconfirmedMessagesExceededException - Exception in akka.persistence
-
- AtLeastOnceDelivery.UnconfirmedDelivery - Class in akka.persistence
-
Information about a message that has not been confirmed.
- AtLeastOnceDelivery.UnconfirmedDelivery$ - Class in akka.persistence
-
- AtLeastOnceDelivery.UnconfirmedWarning - Class in akka.persistence
-
- AtLeastOnceDelivery.UnconfirmedWarning$ - Class in akka.persistence
-
- AtLeastOnceDeliveryLike - Interface in akka.persistence
-
- AtLeastOnceDeliverySnapshot(long, Seq<AtLeastOnceDelivery.UnconfirmedDelivery>) - Constructor for class akka.persistence.AtLeastOnceDelivery.AtLeastOnceDeliverySnapshot
-
- atLeastOnceDeliverySnapshot(MessageFormats.AtLeastOnceDeliverySnapshot) - Method in class akka.persistence.serialization.MessageSerializer
-
- AtLeastOnceDeliverySnapshot$() - Constructor for class akka.persistence.AtLeastOnceDelivery.AtLeastOnceDeliverySnapshot$
-
- atLeastOnceDeliverySnapshotBuilder(AtLeastOnceDelivery.AtLeastOnceDeliverySnapshot) - Method in class akka.persistence.serialization.MessageSerializer
-
- AtLeastOnceDeliverySnapshotClass() - Method in class akka.persistence.serialization.MessageSerializer
-
- AtomicWrite - Class in akka.persistence
-
- AtomicWrite(Seq<PersistentRepr>) - Constructor for class akka.persistence.AtomicWrite
-
- AtomicWrite$ - Class in akka.persistence
-
- AtomicWrite$() - Constructor for class akka.persistence.AtomicWrite$
-
- AtomicWriteClass() - Method in class akka.persistence.serialization.MessageSerializer
-
- attempt() - Method in class akka.persistence.AtLeastOnceDelivery.Internal$.Delivery
-
- autoUpdate() - Method in class akka.persistence.PersistenceSettings.view
-
- autoUpdate() - Method in interface akka.persistence.PersistentView
-
If true
, this view automatically updates itself with an interval specified by autoUpdateInterval
.
- autoUpdateInterval() - Method in class akka.persistence.PersistenceSettings.view
-
- autoUpdateInterval() - Method in interface akka.persistence.PersistentView
-
The interval for automated updates.
- autoUpdateReplayMax() - Method in class akka.persistence.PersistenceSettings.view
-
- autoUpdateReplayMax() - Method in interface akka.persistence.PersistentView
-
The maximum number of messages to replay per update.
- await() - Method in class akka.persistence.Update
-
- generation() - Method in class akka.persistence.fsm.PersistentFSM.TimeoutMarker
-
- generation() - Method in class akka.persistence.fsm.PersistentFSM.Timer
-
- generation() - Method in interface akka.persistence.fsm.PersistentFSMBase
-
- get(Class<?>) - Method in class akka.persistence.journal.EventAdapters
-
Finds the "most specific" matching adapter for the given class (i.e.
- get(Class<?>) - Method in class akka.persistence.journal.IdentityEventAdapters$
-
- get(Class<?>) - Static method in class akka.persistence.journal.IdentityEventAdapters
-
- get(ActorSystem) - Method in class akka.persistence.Persistence$
-
Java API.
- get(ActorSystem) - Static method in class akka.persistence.Persistence
-
Java API.
- getCurrentDeliveryId() - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.Builder
-
required int64 currentDeliveryId = 1;
- getCurrentDeliveryId() - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot
-
required int64 currentDeliveryId = 1;
- getCurrentDeliveryId() - Method in interface akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshotOrBuilder
-
required int64 currentDeliveryId = 1;
- getDefaultInstance() - Static method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot
-
- getDefaultInstance() - Static method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery
-
- getDefaultInstance() - Static method in class akka.persistence.serialization.MessageFormats.AtomicWrite
-
- getDefaultInstance() - Static method in class akka.persistence.serialization.MessageFormats.PersistentMessage
-
- getDefaultInstance() - Static method in class akka.persistence.serialization.MessageFormats.PersistentPayload
-
- getDefaultInstance() - Static method in class akka.persistence.serialization.MessageFormats.PersistentStateChangeEvent
-
- getDefaultInstanceForType() - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.Builder
-
- getDefaultInstanceForType() - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot
-
- getDefaultInstanceForType() - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery.Builder
-
- getDefaultInstanceForType() - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery
-
- getDefaultInstanceForType() - Method in class akka.persistence.serialization.MessageFormats.AtomicWrite.Builder
-
- getDefaultInstanceForType() - Method in class akka.persistence.serialization.MessageFormats.AtomicWrite
-
- getDefaultInstanceForType() - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage.Builder
-
- getDefaultInstanceForType() - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage
-
- getDefaultInstanceForType() - Method in class akka.persistence.serialization.MessageFormats.PersistentPayload.Builder
-
- getDefaultInstanceForType() - Method in class akka.persistence.serialization.MessageFormats.PersistentPayload
-
- getDefaultInstanceForType() - Method in class akka.persistence.serialization.MessageFormats.PersistentStateChangeEvent.Builder
-
- getDefaultInstanceForType() - Method in class akka.persistence.serialization.MessageFormats.PersistentStateChangeEvent
-
- getDeleted() - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage.Builder
-
optional bool deleted = 4;
- getDeleted() - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage
-
optional bool deleted = 4;
- getDeleted() - Method in interface akka.persistence.serialization.MessageFormats.PersistentMessageOrBuilder
-
optional bool deleted = 4;
- getDeliveryId() - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery.Builder
-
required int64 deliveryId = 1;
- getDeliveryId() - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery
-
required int64 deliveryId = 1;
- getDeliveryId() - Method in interface akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDeliveryOrBuilder
-
required int64 deliveryId = 1;
- getDeliverySnapshot() - Method in interface akka.persistence.AtLeastOnceDeliveryLike
-
Full state of the AtLeastOnceDelivery
.
- getDescriptor() - Static method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.Builder
-
- getDescriptor() - Static method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot
-
- getDescriptor() - Static method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery.Builder
-
- getDescriptor() - Static method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery
-
- getDescriptor() - Static method in class akka.persistence.serialization.MessageFormats.AtomicWrite.Builder
-
- getDescriptor() - Static method in class akka.persistence.serialization.MessageFormats.AtomicWrite
-
- getDescriptor() - Static method in class akka.persistence.serialization.MessageFormats
-
- getDescriptor() - Static method in class akka.persistence.serialization.MessageFormats.PersistentMessage.Builder
-
- getDescriptor() - Static method in class akka.persistence.serialization.MessageFormats.PersistentMessage
-
- getDescriptor() - Static method in class akka.persistence.serialization.MessageFormats.PersistentPayload.Builder
-
- getDescriptor() - Static method in class akka.persistence.serialization.MessageFormats.PersistentPayload
-
- getDescriptor() - Static method in class akka.persistence.serialization.MessageFormats.PersistentStateChangeEvent.Builder
-
- getDescriptor() - Static method in class akka.persistence.serialization.MessageFormats.PersistentStateChangeEvent
-
- getDescriptorForType() - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.Builder
-
- getDescriptorForType() - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery.Builder
-
- getDescriptorForType() - Method in class akka.persistence.serialization.MessageFormats.AtomicWrite.Builder
-
- getDescriptorForType() - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage.Builder
-
- getDescriptorForType() - Method in class akka.persistence.serialization.MessageFormats.PersistentPayload.Builder
-
- getDescriptorForType() - Method in class akka.persistence.serialization.MessageFormats.PersistentStateChangeEvent.Builder
-
- getDestination() - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery.Builder
-
required string destination = 2;
- getDestination() - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery
-
required string destination = 2;
- getDestination() - Method in interface akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDeliveryOrBuilder
-
required string destination = 2;
- getDestinationBytes() - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery.Builder
-
required string destination = 2;
- getDestinationBytes() - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery
-
required string destination = 2;
- getDestinationBytes() - Method in interface akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDeliveryOrBuilder
-
required string destination = 2;
- getInstance() - Method in class akka.persistence.RecoveryCompleted$
-
Java API: get the singleton instance
- getInstance() - Static method in class akka.persistence.RecoveryCompleted
-
Java API: get the singleton instance
- getLog() - Method in interface akka.persistence.fsm.LoggingPersistentFSM
-
Retrieve current rolling log in oldest-first order.
- getManifest() - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage.Builder
-
optional string manifest = 12;
- getManifest() - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage
-
optional string manifest = 12;
- getManifest() - Method in interface akka.persistence.serialization.MessageFormats.PersistentMessageOrBuilder
-
optional string manifest = 12;
- getManifestBytes() - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage.Builder
-
optional string manifest = 12;
- getManifestBytes() - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage
-
optional string manifest = 12;
- getManifestBytes() - Method in interface akka.persistence.serialization.MessageFormats.PersistentMessageOrBuilder
-
optional string manifest = 12;
- getMessage() - Method in class akka.persistence.AtLeastOnceDelivery.UnconfirmedDelivery
-
Java API
- getParserForType() - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot
-
- getParserForType() - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery
-
- getParserForType() - Method in class akka.persistence.serialization.MessageFormats.AtomicWrite
-
- getParserForType() - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage
-
- getParserForType() - Method in class akka.persistence.serialization.MessageFormats.PersistentPayload
-
- getParserForType() - Method in class akka.persistence.serialization.MessageFormats.PersistentStateChangeEvent
-
- getPayload() - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery.Builder
-
required .PersistentPayload payload = 3;
- getPayload() - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery
-
required .PersistentPayload payload = 3;
- getPayload() - Method in interface akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDeliveryOrBuilder
-
required .PersistentPayload payload = 3;
- getPayload(int) - Method in class akka.persistence.serialization.MessageFormats.AtomicWrite.Builder
-
repeated .PersistentMessage payload = 1;
- getPayload(int) - Method in class akka.persistence.serialization.MessageFormats.AtomicWrite
-
repeated .PersistentMessage payload = 1;
- getPayload(int) - Method in interface akka.persistence.serialization.MessageFormats.AtomicWriteOrBuilder
-
repeated .PersistentMessage payload = 1;
- getPayload() - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage.Builder
-
optional .PersistentPayload payload = 1;
- getPayload() - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage
-
optional .PersistentPayload payload = 1;
- getPayload() - Method in interface akka.persistence.serialization.MessageFormats.PersistentMessageOrBuilder
-
optional .PersistentPayload payload = 1;
- getPayload() - Method in class akka.persistence.serialization.MessageFormats.PersistentPayload.Builder
-
required bytes payload = 2;
- getPayload() - Method in class akka.persistence.serialization.MessageFormats.PersistentPayload
-
required bytes payload = 2;
- getPayload() - Method in interface akka.persistence.serialization.MessageFormats.PersistentPayloadOrBuilder
-
required bytes payload = 2;
- getPayloadBuilder() - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery.Builder
-
required .PersistentPayload payload = 3;
- getPayloadBuilder(int) - Method in class akka.persistence.serialization.MessageFormats.AtomicWrite.Builder
-
repeated .PersistentMessage payload = 1;
- getPayloadBuilder() - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage.Builder
-
optional .PersistentPayload payload = 1;
- getPayloadBuilderList() - Method in class akka.persistence.serialization.MessageFormats.AtomicWrite.Builder
-
repeated .PersistentMessage payload = 1;
- getPayloadCount() - Method in class akka.persistence.serialization.MessageFormats.AtomicWrite.Builder
-
repeated .PersistentMessage payload = 1;
- getPayloadCount() - Method in class akka.persistence.serialization.MessageFormats.AtomicWrite
-
repeated .PersistentMessage payload = 1;
- getPayloadCount() - Method in interface akka.persistence.serialization.MessageFormats.AtomicWriteOrBuilder
-
repeated .PersistentMessage payload = 1;
- getPayloadList() - Method in class akka.persistence.serialization.MessageFormats.AtomicWrite.Builder
-
repeated .PersistentMessage payload = 1;
- getPayloadList() - Method in class akka.persistence.serialization.MessageFormats.AtomicWrite
-
repeated .PersistentMessage payload = 1;
- getPayloadList() - Method in interface akka.persistence.serialization.MessageFormats.AtomicWriteOrBuilder
-
repeated .PersistentMessage payload = 1;
- getPayloadManifest() - Method in class akka.persistence.serialization.MessageFormats.PersistentPayload.Builder
-
optional bytes payloadManifest = 3;
- getPayloadManifest() - Method in class akka.persistence.serialization.MessageFormats.PersistentPayload
-
optional bytes payloadManifest = 3;
- getPayloadManifest() - Method in interface akka.persistence.serialization.MessageFormats.PersistentPayloadOrBuilder
-
optional bytes payloadManifest = 3;
- getPayloadOrBuilder() - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery.Builder
-
required .PersistentPayload payload = 3;
- getPayloadOrBuilder() - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery
-
required .PersistentPayload payload = 3;
- getPayloadOrBuilder() - Method in interface akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDeliveryOrBuilder
-
required .PersistentPayload payload = 3;
- getPayloadOrBuilder(int) - Method in class akka.persistence.serialization.MessageFormats.AtomicWrite.Builder
-
repeated .PersistentMessage payload = 1;
- getPayloadOrBuilder(int) - Method in class akka.persistence.serialization.MessageFormats.AtomicWrite
-
repeated .PersistentMessage payload = 1;
- getPayloadOrBuilder(int) - Method in interface akka.persistence.serialization.MessageFormats.AtomicWriteOrBuilder
-
repeated .PersistentMessage payload = 1;
- getPayloadOrBuilder() - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage.Builder
-
optional .PersistentPayload payload = 1;
- getPayloadOrBuilder() - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage
-
optional .PersistentPayload payload = 1;
- getPayloadOrBuilder() - Method in interface akka.persistence.serialization.MessageFormats.PersistentMessageOrBuilder
-
optional .PersistentPayload payload = 1;
- getPayloadOrBuilderList() - Method in class akka.persistence.serialization.MessageFormats.AtomicWrite.Builder
-
repeated .PersistentMessage payload = 1;
- getPayloadOrBuilderList() - Method in class akka.persistence.serialization.MessageFormats.AtomicWrite
-
repeated .PersistentMessage payload = 1;
- getPayloadOrBuilderList() - Method in interface akka.persistence.serialization.MessageFormats.AtomicWriteOrBuilder
-
repeated .PersistentMessage payload = 1;
- getPersistenceId() - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage.Builder
-
optional string persistenceId = 3;
- getPersistenceId() - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage
-
optional string persistenceId = 3;
- getPersistenceId() - Method in interface akka.persistence.serialization.MessageFormats.PersistentMessageOrBuilder
-
optional string persistenceId = 3;
- getPersistenceIdBytes() - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage.Builder
-
optional string persistenceId = 3;
- getPersistenceIdBytes() - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage
-
optional string persistenceId = 3;
- getPersistenceIdBytes() - Method in interface akka.persistence.serialization.MessageFormats.PersistentMessageOrBuilder
-
optional string persistenceId = 3;
- getSender() - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage.Builder
-
optional string sender = 11;
- getSender() - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage
-
optional string sender = 11;
- getSender() - Method in interface akka.persistence.serialization.MessageFormats.PersistentMessageOrBuilder
-
optional string sender = 11;
- getSenderBytes() - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage.Builder
-
optional string sender = 11;
- getSenderBytes() - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage
-
optional string sender = 11;
- getSenderBytes() - Method in interface akka.persistence.serialization.MessageFormats.PersistentMessageOrBuilder
-
optional string sender = 11;
- getSequenceNr() - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage.Builder
-
optional int64 sequenceNr = 2;
- getSequenceNr() - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage
-
optional int64 sequenceNr = 2;
- getSequenceNr() - Method in interface akka.persistence.serialization.MessageFormats.PersistentMessageOrBuilder
-
optional int64 sequenceNr = 2;
- getSerializedSize() - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot
-
- getSerializedSize() - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery
-
- getSerializedSize() - Method in class akka.persistence.serialization.MessageFormats.AtomicWrite
-
- getSerializedSize() - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage
-
- getSerializedSize() - Method in class akka.persistence.serialization.MessageFormats.PersistentPayload
-
- getSerializedSize() - Method in class akka.persistence.serialization.MessageFormats.PersistentStateChangeEvent
-
- getSerializerId() - Method in class akka.persistence.serialization.MessageFormats.PersistentPayload.Builder
-
required int32 serializerId = 1;
- getSerializerId() - Method in class akka.persistence.serialization.MessageFormats.PersistentPayload
-
required int32 serializerId = 1;
- getSerializerId() - Method in interface akka.persistence.serialization.MessageFormats.PersistentPayloadOrBuilder
-
required int32 serializerId = 1;
- getStateIdentifier() - Method in class akka.persistence.serialization.MessageFormats.PersistentStateChangeEvent.Builder
-
required string stateIdentifier = 1;
- getStateIdentifier() - Method in class akka.persistence.serialization.MessageFormats.PersistentStateChangeEvent
-
required string stateIdentifier = 1;
- getStateIdentifier() - Method in interface akka.persistence.serialization.MessageFormats.PersistentStateChangeEventOrBuilder
-
required string stateIdentifier = 1;
- getStateIdentifierBytes() - Method in class akka.persistence.serialization.MessageFormats.PersistentStateChangeEvent.Builder
-
required string stateIdentifier = 1;
- getStateIdentifierBytes() - Method in class akka.persistence.serialization.MessageFormats.PersistentStateChangeEvent
-
required string stateIdentifier = 1;
- getStateIdentifierBytes() - Method in interface akka.persistence.serialization.MessageFormats.PersistentStateChangeEventOrBuilder
-
required string stateIdentifier = 1;
- getTimeout() - Method in class akka.persistence.serialization.MessageFormats.PersistentStateChangeEvent.Builder
-
optional string timeout = 2;
- getTimeout() - Method in class akka.persistence.serialization.MessageFormats.PersistentStateChangeEvent
-
optional string timeout = 2;
- getTimeout() - Method in interface akka.persistence.serialization.MessageFormats.PersistentStateChangeEventOrBuilder
-
optional string timeout = 2;
- getTimeoutBytes() - Method in class akka.persistence.serialization.MessageFormats.PersistentStateChangeEvent.Builder
-
optional string timeout = 2;
- getTimeoutBytes() - Method in class akka.persistence.serialization.MessageFormats.PersistentStateChangeEvent
-
optional string timeout = 2;
- getTimeoutBytes() - Method in interface akka.persistence.serialization.MessageFormats.PersistentStateChangeEventOrBuilder
-
optional string timeout = 2;
- getUnconfirmedDeliveries() - Method in class akka.persistence.AtLeastOnceDelivery.AtLeastOnceDeliverySnapshot
-
Java API
- getUnconfirmedDeliveries() - Method in class akka.persistence.AtLeastOnceDelivery.UnconfirmedWarning
-
Java API
- getUnconfirmedDeliveries(int) - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.Builder
-
repeated .AtLeastOnceDeliverySnapshot.UnconfirmedDelivery unconfirmedDeliveries = 2;
- getUnconfirmedDeliveries(int) - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot
-
repeated .AtLeastOnceDeliverySnapshot.UnconfirmedDelivery unconfirmedDeliveries = 2;
- getUnconfirmedDeliveries(int) - Method in interface akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshotOrBuilder
-
repeated .AtLeastOnceDeliverySnapshot.UnconfirmedDelivery unconfirmedDeliveries = 2;
- getUnconfirmedDeliveriesBuilder(int) - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.Builder
-
repeated .AtLeastOnceDeliverySnapshot.UnconfirmedDelivery unconfirmedDeliveries = 2;
- getUnconfirmedDeliveriesBuilderList() - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.Builder
-
repeated .AtLeastOnceDeliverySnapshot.UnconfirmedDelivery unconfirmedDeliveries = 2;
- getUnconfirmedDeliveriesCount() - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.Builder
-
repeated .AtLeastOnceDeliverySnapshot.UnconfirmedDelivery unconfirmedDeliveries = 2;
- getUnconfirmedDeliveriesCount() - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot
-
repeated .AtLeastOnceDeliverySnapshot.UnconfirmedDelivery unconfirmedDeliveries = 2;
- getUnconfirmedDeliveriesCount() - Method in interface akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshotOrBuilder
-
repeated .AtLeastOnceDeliverySnapshot.UnconfirmedDelivery unconfirmedDeliveries = 2;
- getUnconfirmedDeliveriesList() - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.Builder
-
repeated .AtLeastOnceDeliverySnapshot.UnconfirmedDelivery unconfirmedDeliveries = 2;
- getUnconfirmedDeliveriesList() - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot
-
repeated .AtLeastOnceDeliverySnapshot.UnconfirmedDelivery unconfirmedDeliveries = 2;
- getUnconfirmedDeliveriesList() - Method in interface akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshotOrBuilder
-
repeated .AtLeastOnceDeliverySnapshot.UnconfirmedDelivery unconfirmedDeliveries = 2;
- getUnconfirmedDeliveriesOrBuilder(int) - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.Builder
-
repeated .AtLeastOnceDeliverySnapshot.UnconfirmedDelivery unconfirmedDeliveries = 2;
- getUnconfirmedDeliveriesOrBuilder(int) - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot
-
repeated .AtLeastOnceDeliverySnapshot.UnconfirmedDelivery unconfirmedDeliveries = 2;
- getUnconfirmedDeliveriesOrBuilder(int) - Method in interface akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshotOrBuilder
-
repeated .AtLeastOnceDeliverySnapshot.UnconfirmedDelivery unconfirmedDeliveries = 2;
- getUnconfirmedDeliveriesOrBuilderList() - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.Builder
-
repeated .AtLeastOnceDeliverySnapshot.UnconfirmedDelivery unconfirmedDeliveries = 2;
- getUnconfirmedDeliveriesOrBuilderList() - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot
-
repeated .AtLeastOnceDeliverySnapshot.UnconfirmedDelivery unconfirmedDeliveries = 2;
- getUnconfirmedDeliveriesOrBuilderList() - Method in interface akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshotOrBuilder
-
repeated .AtLeastOnceDeliverySnapshot.UnconfirmedDelivery unconfirmedDeliveries = 2;
- getUnknownFields() - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot
-
- getUnknownFields() - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery
-
- getUnknownFields() - Method in class akka.persistence.serialization.MessageFormats.AtomicWrite
-
- getUnknownFields() - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage
-
- getUnknownFields() - Method in class akka.persistence.serialization.MessageFormats.PersistentPayload
-
- getUnknownFields() - Method in class akka.persistence.serialization.MessageFormats.PersistentStateChangeEvent
-
- getWriterUuid() - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage.Builder
-
optional string writerUuid = 13;
- getWriterUuid() - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage
-
optional string writerUuid = 13;
- getWriterUuid() - Method in interface akka.persistence.serialization.MessageFormats.PersistentMessageOrBuilder
-
optional string writerUuid = 13;
- getWriterUuidBytes() - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage.Builder
-
optional string writerUuid = 13;
- getWriterUuidBytes() - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage
-
optional string writerUuid = 13;
- getWriterUuidBytes() - Method in interface akka.persistence.serialization.MessageFormats.PersistentMessageOrBuilder
-
optional string writerUuid = 13;
- goTo(S) - Method in class akka.persistence.fsm.AbstractPersistentFSMBase
-
Produce transition to other state.
- handleEvent() - Method in interface akka.persistence.fsm.PersistentFSMBase
-
- handleEventDefault() - Method in interface akka.persistence.fsm.PersistentFSMBase
-
- handler() - Method in class akka.persistence.Eventsourced.AsyncHandlerInvocation
-
- handler() - Method in interface akka.persistence.Eventsourced.PendingHandlerInvocation
-
- handler() - Method in class akka.persistence.Eventsourced.StashingHandlerInvocation
-
- handleTransition(S, S) - Method in interface akka.persistence.fsm.PersistentFSMBase
-
- hasAllPersistenceIdsSubscribers() - Method in interface akka.persistence.journal.leveldb.LeveldbStore
-
- hasCurrentDeliveryId() - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.Builder
-
required int64 currentDeliveryId = 1;
- hasCurrentDeliveryId() - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot
-
required int64 currentDeliveryId = 1;
- hasCurrentDeliveryId() - Method in interface akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshotOrBuilder
-
required int64 currentDeliveryId = 1;
- hasDeleted() - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage.Builder
-
optional bool deleted = 4;
- hasDeleted() - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage
-
optional bool deleted = 4;
- hasDeleted() - Method in interface akka.persistence.serialization.MessageFormats.PersistentMessageOrBuilder
-
optional bool deleted = 4;
- hasDeliveryId() - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery.Builder
-
required int64 deliveryId = 1;
- hasDeliveryId() - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery
-
required int64 deliveryId = 1;
- hasDeliveryId() - Method in interface akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDeliveryOrBuilder
-
required int64 deliveryId = 1;
- hasDestination() - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery.Builder
-
required string destination = 2;
- hasDestination() - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery
-
required string destination = 2;
- hasDestination() - Method in interface akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDeliveryOrBuilder
-
required string destination = 2;
- hasManifest() - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage.Builder
-
optional string manifest = 12;
- hasManifest() - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage
-
optional string manifest = 12;
- hasManifest() - Method in interface akka.persistence.serialization.MessageFormats.PersistentMessageOrBuilder
-
optional string manifest = 12;
- hasPayload() - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery.Builder
-
required .PersistentPayload payload = 3;
- hasPayload() - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery
-
required .PersistentPayload payload = 3;
- hasPayload() - Method in interface akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDeliveryOrBuilder
-
required .PersistentPayload payload = 3;
- hasPayload() - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage.Builder
-
optional .PersistentPayload payload = 1;
- hasPayload() - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage
-
optional .PersistentPayload payload = 1;
- hasPayload() - Method in interface akka.persistence.serialization.MessageFormats.PersistentMessageOrBuilder
-
optional .PersistentPayload payload = 1;
- hasPayload() - Method in class akka.persistence.serialization.MessageFormats.PersistentPayload.Builder
-
required bytes payload = 2;
- hasPayload() - Method in class akka.persistence.serialization.MessageFormats.PersistentPayload
-
required bytes payload = 2;
- hasPayload() - Method in interface akka.persistence.serialization.MessageFormats.PersistentPayloadOrBuilder
-
required bytes payload = 2;
- hasPayloadManifest() - Method in class akka.persistence.serialization.MessageFormats.PersistentPayload.Builder
-
optional bytes payloadManifest = 3;
- hasPayloadManifest() - Method in class akka.persistence.serialization.MessageFormats.PersistentPayload
-
optional bytes payloadManifest = 3;
- hasPayloadManifest() - Method in interface akka.persistence.serialization.MessageFormats.PersistentPayloadOrBuilder
-
optional bytes payloadManifest = 3;
- hasPersistenceId() - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage.Builder
-
optional string persistenceId = 3;
- hasPersistenceId() - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage
-
optional string persistenceId = 3;
- hasPersistenceId() - Method in interface akka.persistence.serialization.MessageFormats.PersistentMessageOrBuilder
-
optional string persistenceId = 3;
- hasPersistenceIdSubscribers() - Method in interface akka.persistence.journal.leveldb.LeveldbStore
-
- hasSender() - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage.Builder
-
optional string sender = 11;
- hasSender() - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage
-
optional string sender = 11;
- hasSender() - Method in interface akka.persistence.serialization.MessageFormats.PersistentMessageOrBuilder
-
optional string sender = 11;
- hasSequenceNr() - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage.Builder
-
optional int64 sequenceNr = 2;
- hasSequenceNr() - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage
-
optional int64 sequenceNr = 2;
- hasSequenceNr() - Method in interface akka.persistence.serialization.MessageFormats.PersistentMessageOrBuilder
-
optional int64 sequenceNr = 2;
- hasSerializerId() - Method in class akka.persistence.serialization.MessageFormats.PersistentPayload.Builder
-
required int32 serializerId = 1;
- hasSerializerId() - Method in class akka.persistence.serialization.MessageFormats.PersistentPayload
-
required int32 serializerId = 1;
- hasSerializerId() - Method in interface akka.persistence.serialization.MessageFormats.PersistentPayloadOrBuilder
-
required int32 serializerId = 1;
- hasStateIdentifier() - Method in class akka.persistence.serialization.MessageFormats.PersistentStateChangeEvent.Builder
-
required string stateIdentifier = 1;
- hasStateIdentifier() - Method in class akka.persistence.serialization.MessageFormats.PersistentStateChangeEvent
-
required string stateIdentifier = 1;
- hasStateIdentifier() - Method in interface akka.persistence.serialization.MessageFormats.PersistentStateChangeEventOrBuilder
-
required string stateIdentifier = 1;
- hasTagSubscribers() - Method in interface akka.persistence.journal.leveldb.LeveldbStore
-
- hasTimeout() - Method in class akka.persistence.serialization.MessageFormats.PersistentStateChangeEvent.Builder
-
optional string timeout = 2;
- hasTimeout() - Method in class akka.persistence.serialization.MessageFormats.PersistentStateChangeEvent
-
optional string timeout = 2;
- hasTimeout() - Method in interface akka.persistence.serialization.MessageFormats.PersistentStateChangeEventOrBuilder
-
optional string timeout = 2;
- hasWriterUuid() - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage.Builder
-
optional string writerUuid = 13;
- hasWriterUuid() - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage
-
optional string writerUuid = 13;
- hasWriterUuid() - Method in interface akka.persistence.serialization.MessageFormats.PersistentMessageOrBuilder
-
optional string writerUuid = 13;
- highestSequenceNr() - Method in class akka.persistence.AtomicWrite
-
- highestSequenceNr() - Method in class akka.persistence.journal.AsyncWriteTarget.ReplaySuccess
-
- highestSequenceNr(String) - Method in interface akka.persistence.journal.inmem.InmemMessages
-
- highestSequenceNr() - Method in class akka.persistence.JournalProtocol.RecoverySuccess
-
- makeTransition(PersistentFSM.State<S, D, E>) - Method in interface akka.persistence.fsm.PersistentFSMBase
-
- manifest(Object) - Method in class akka.persistence.journal.EventAdapters.CombinedReadEventAdapter
-
- manifest(Object) - Method in class akka.persistence.journal.IdentityEventAdapter$
-
- manifest(Object) - Static method in class akka.persistence.journal.IdentityEventAdapter
-
- manifest(Object) - Method in class akka.persistence.journal.NoopReadEventAdapter
-
- manifest(Object) - Method in class akka.persistence.journal.NoopWriteEventAdapter
-
- manifest(Object) - Method in interface akka.persistence.journal.WriteEventAdapter
-
Return the manifest (type hint) that will be provided in the fromJournal
method.
- manifest() - Method in class akka.persistence.PersistentImpl
-
- manifest() - Method in interface akka.persistence.PersistentRepr
-
Returns the persistent payload's manifest if available
- manifest() - Method in class akka.persistence.serialization.SnapshotHeader
-
- MANIFEST_FIELD_NUMBER - Static variable in class akka.persistence.serialization.MessageFormats.PersistentMessage
-
- mappingId() - Method in class akka.persistence.journal.leveldb.Key
-
- mappingKey(int) - Method in class akka.persistence.journal.leveldb.Key$
-
- mappingKey(int) - Static method in class akka.persistence.journal.leveldb.Key
-
- matchAnyEvent(FI.Apply2<Object, D, PersistentFSM.State<S, D, E>>) - Method in class akka.persistence.fsm.AbstractPersistentFSMBase
-
Create an FSMStateFunctionBuilder
with the first case statement set.
- matchData(Class<DT>, FI.UnitApply<DT>) - Method in class akka.persistence.fsm.AbstractPersistentFSMBase
-
Create a UnitPFBuilder
with the first case statement set.
- matchData(Class<DT>, FI.TypedPredicate<DT>, FI.UnitApply<DT>) - Method in class akka.persistence.fsm.AbstractPersistentFSMBase
-
Create a UnitPFBuilder
with the first case statement set.
- matches(SnapshotMetadata) - Method in class akka.persistence.SnapshotSelectionCriteria
-
INTERNAL API.
- matchEvent(Class<ET>, Class<DT>, FI.TypedPredicate2<ET, DT>, FI.Apply2<ET, DT, PersistentFSM.State<S, D, E>>) - Method in class akka.persistence.fsm.AbstractPersistentFSMBase
-
Create an FSMStateFunctionBuilder
with the first case statement set.
- matchEvent(Class<ET>, Class<DT>, FI.Apply2<ET, DT, PersistentFSM.State<S, D, E>>) - Method in class akka.persistence.fsm.AbstractPersistentFSMBase
-
Create an FSMStateFunctionBuilder
with the first case statement set.
- matchEvent(Class<ET>, FI.TypedPredicate2<ET, D>, FI.Apply2<ET, D, PersistentFSM.State<S, D, E>>) - Method in class akka.persistence.fsm.AbstractPersistentFSMBase
-
Create an FSMStateFunctionBuilder
with the first case statement set.
- matchEvent(Class<ET>, FI.Apply2<ET, D, PersistentFSM.State<S, D, E>>) - Method in class akka.persistence.fsm.AbstractPersistentFSMBase
-
Create an FSMStateFunctionBuilder
with the first case statement set.
- matchEvent(FI.TypedPredicate2<Object, D>, FI.Apply2<Object, D, PersistentFSM.State<S, D, E>>) - Method in class akka.persistence.fsm.AbstractPersistentFSMBase
-
Create an FSMStateFunctionBuilder
with the first case statement set.
- matchEvent(List<Object>, Class<DT>, FI.Apply2<Object, DT, PersistentFSM.State<S, D, E>>) - Method in class akka.persistence.fsm.AbstractPersistentFSMBase
-
Create an FSMStateFunctionBuilder
with the first case statement set.
- matchEvent(List<Object>, FI.Apply2<Object, D, PersistentFSM.State<S, D, E>>) - Method in class akka.persistence.fsm.AbstractPersistentFSMBase
-
Create an FSMStateFunctionBuilder
with the first case statement set.
- matchEventEquals(Ev, Class<DT>, FI.Apply2<Ev, DT, PersistentFSM.State<S, D, E>>) - Method in class akka.persistence.fsm.AbstractPersistentFSMBase
-
Create an FSMStateFunctionBuilder
with the first case statement set.
- matchEventEquals(Ev, FI.Apply2<Ev, D, PersistentFSM.State<S, D, E>>) - Method in class akka.persistence.fsm.AbstractPersistentFSMBase
-
Create an FSMStateFunctionBuilder
with the first case statement set.
- matchState(S, S, FI.UnitApplyVoid) - Method in class akka.persistence.fsm.AbstractPersistentFSMBase
-
Create an FSMTransitionHandlerBuilder
with the first case statement set.
- matchState(S, S, FI.UnitApply2<S, S>) - Method in class akka.persistence.fsm.AbstractPersistentFSMBase
-
Create an FSMTransitionHandlerBuilder
with the first case statement set.
- matchStop(PersistentFSM.Reason, FI.UnitApply2<S, D>) - Method in class akka.persistence.fsm.AbstractPersistentFSMBase
-
Create an FSMStopBuilder
with the first case statement set.
- matchStop(Class<RT>, FI.UnitApply3<RT, S, D>) - Method in class akka.persistence.fsm.AbstractPersistentFSMBase
-
Create an FSMStopBuilder
with the first case statement set.
- matchStop(Class<RT>, FI.TypedPredicate<RT>, FI.UnitApply3<RT, S, D>) - Method in class akka.persistence.fsm.AbstractPersistentFSMBase
-
Create an FSMStopBuilder
with the first case statement set.
- max() - Method in class akka.persistence.journal.AsyncWriteTarget.ReplayMessages
-
- max() - Method in class akka.persistence.journal.leveldb.LeveldbJournal.ReplayTaggedMessages
-
- max() - Method in class akka.persistence.JournalProtocol.ReplayMessages
-
- maxMessageBatchSize() - Method in interface akka.persistence.Eventsourced
-
- maxSequenceNr() - Method in class akka.persistence.SnapshotSelectionCriteria
-
- maxTimestamp() - Method in class akka.persistence.SnapshotSelectionCriteria
-
- maxUnconfirmedMessages() - Method in interface akka.persistence.AtLeastOnceDeliveryLike
-
Maximum number of unconfirmed messages that this actor is allowed to hold in memory.
- maxUnconfirmedMessages() - Method in class akka.persistence.PersistenceSettings.atLeastOnceDelivery
-
- MaxUnconfirmedMessagesExceededException(String) - Constructor for exception akka.persistence.AtLeastOnceDelivery.MaxUnconfirmedMessagesExceededException
-
- mergeFrom(Message) - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.Builder
-
- mergeFrom(MessageFormats.AtLeastOnceDeliverySnapshot) - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.Builder
-
- mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.Builder
-
- mergeFrom(Message) - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery.Builder
-
- mergeFrom(MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery) - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery.Builder
-
- mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery.Builder
-
- mergeFrom(Message) - Method in class akka.persistence.serialization.MessageFormats.AtomicWrite.Builder
-
- mergeFrom(MessageFormats.AtomicWrite) - Method in class akka.persistence.serialization.MessageFormats.AtomicWrite.Builder
-
- mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class akka.persistence.serialization.MessageFormats.AtomicWrite.Builder
-
- mergeFrom(Message) - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage.Builder
-
- mergeFrom(MessageFormats.PersistentMessage) - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage.Builder
-
- mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage.Builder
-
- mergeFrom(Message) - Method in class akka.persistence.serialization.MessageFormats.PersistentPayload.Builder
-
- mergeFrom(MessageFormats.PersistentPayload) - Method in class akka.persistence.serialization.MessageFormats.PersistentPayload.Builder
-
- mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class akka.persistence.serialization.MessageFormats.PersistentPayload.Builder
-
- mergeFrom(Message) - Method in class akka.persistence.serialization.MessageFormats.PersistentStateChangeEvent.Builder
-
- mergeFrom(MessageFormats.PersistentStateChangeEvent) - Method in class akka.persistence.serialization.MessageFormats.PersistentStateChangeEvent.Builder
-
- mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class akka.persistence.serialization.MessageFormats.PersistentStateChangeEvent.Builder
-
- mergePayload(MessageFormats.PersistentPayload) - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery.Builder
-
required .PersistentPayload payload = 3;
- mergePayload(MessageFormats.PersistentPayload) - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage.Builder
-
optional .PersistentPayload payload = 1;
- message() - Method in class akka.persistence.AtLeastOnceDelivery.Internal$.Delivery
-
- message() - Method in class akka.persistence.AtLeastOnceDelivery.UnconfirmedDelivery
-
- message() - Method in class akka.persistence.JournalProtocol.LoopMessageSuccess
-
- message() - Method in class akka.persistence.JournalProtocol.WriteMessageFailure
-
- message() - Method in class akka.persistence.JournalProtocol.WriteMessageRejected
-
- Message - Interface in akka.persistence.serialization
-
Marker trait for all protobuf-serializable messages in akka.persistence
.
- MessageFormats - Class in akka.persistence.serialization
-
- MessageFormats.AtLeastOnceDeliverySnapshot - Class in akka.persistence.serialization
-
Protobuf type AtLeastOnceDeliverySnapshot
- MessageFormats.AtLeastOnceDeliverySnapshot.Builder - Class in akka.persistence.serialization
-
Protobuf type AtLeastOnceDeliverySnapshot
- MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery - Class in akka.persistence.serialization
-
Protobuf type AtLeastOnceDeliverySnapshot.UnconfirmedDelivery
- MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery.Builder - Class in akka.persistence.serialization
-
Protobuf type AtLeastOnceDeliverySnapshot.UnconfirmedDelivery
- MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDeliveryOrBuilder - Interface in akka.persistence.serialization
-
- MessageFormats.AtLeastOnceDeliverySnapshotOrBuilder - Interface in akka.persistence.serialization
-
- MessageFormats.AtomicWrite - Class in akka.persistence.serialization
-
Protobuf type AtomicWrite
- MessageFormats.AtomicWrite.Builder - Class in akka.persistence.serialization
-
Protobuf type AtomicWrite
- MessageFormats.AtomicWriteOrBuilder - Interface in akka.persistence.serialization
-
- MessageFormats.PersistentMessage - Class in akka.persistence.serialization
-
Protobuf type PersistentMessage
- MessageFormats.PersistentMessage.Builder - Class in akka.persistence.serialization
-
Protobuf type PersistentMessage
- MessageFormats.PersistentMessageOrBuilder - Interface in akka.persistence.serialization
-
- MessageFormats.PersistentPayload - Class in akka.persistence.serialization
-
Protobuf type PersistentPayload
- MessageFormats.PersistentPayload.Builder - Class in akka.persistence.serialization
-
Protobuf type PersistentPayload
- MessageFormats.PersistentPayloadOrBuilder - Interface in akka.persistence.serialization
-
- MessageFormats.PersistentStateChangeEvent - Class in akka.persistence.serialization
-
Protobuf type PersistentStateChangeEvent
- MessageFormats.PersistentStateChangeEvent.Builder - Class in akka.persistence.serialization
-
Protobuf type PersistentStateChangeEvent
- MessageFormats.PersistentStateChangeEventOrBuilder - Interface in akka.persistence.serialization
-
- messages() - Method in class akka.persistence.journal.AsyncWriteTarget.WriteMessages
-
- messages() - Method in interface akka.persistence.journal.inmem.InmemMessages
-
- messages() - Method in class akka.persistence.JournalProtocol.WriteMessages
-
- MessageSerializer - Class in akka.persistence.serialization
-
- MessageSerializer(ExtendedActorSystem) - Constructor for class akka.persistence.serialization.MessageSerializer
-
- metadata() - Method in class akka.persistence.DeleteSnapshotFailure
-
- metadata() - Method in class akka.persistence.DeleteSnapshotSuccess
-
- metadata() - Method in class akka.persistence.SaveSnapshotFailure
-
- metadata() - Method in class akka.persistence.SaveSnapshotSuccess
-
- metadata() - Method in class akka.persistence.SelectedSnapshot
-
- metadata() - Method in class akka.persistence.SnapshotOffer
-
- metadata() - Method in class akka.persistence.SnapshotProtocol.DeleteSnapshot
-
- metadata() - Method in class akka.persistence.SnapshotProtocol.SaveSnapshot
-
- minSequenceNr() - Method in class akka.persistence.SnapshotSelectionCriteria
-
- minTimestamp() - Method in class akka.persistence.SnapshotSelectionCriteria
-
- MODULE$ - Static variable in class akka.persistence.AtLeastOnceDelivery$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.AtLeastOnceDelivery.AtLeastOnceDeliverySnapshot$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.AtLeastOnceDelivery.Internal$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.AtLeastOnceDelivery.UnconfirmedDelivery$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.AtLeastOnceDelivery.UnconfirmedWarning$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.AtomicWrite$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.DeleteMessagesFailure$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.DeleteMessagesSuccess$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.DeleteSnapshotFailure$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.DeleteSnapshotsFailure$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.DeleteSnapshotsSuccess$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.DeleteSnapshotSuccess$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.Eventsourced$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.Eventsourced.AsyncHandlerInvocation$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.Eventsourced.StashingHandlerInvocation$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.fsm.AbstractPersistentFSMBase$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.fsm.PersistentFSM$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.fsm.PersistentFSM.$minus$greater$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.fsm.PersistentFSM.CurrentState$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.fsm.PersistentFSM.Event$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.fsm.PersistentFSM.Failure$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.fsm.PersistentFSM.LogEntry$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.fsm.PersistentFSM.Normal$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.fsm.PersistentFSM.NullFunction$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.fsm.PersistentFSM.Shutdown$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.fsm.PersistentFSM.State$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.fsm.PersistentFSM.StateChangeEvent$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.fsm.PersistentFSM.StateTimeout$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.fsm.PersistentFSM.StopEvent$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.fsm.PersistentFSM.SubscribeTransitionCallBack$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.fsm.PersistentFSM.TimeoutMarker$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.fsm.PersistentFSM.Timer$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.fsm.PersistentFSM.Transition$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.fsm.PersistentFSM.UnsubscribeTransitionCallBack$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.journal.AsyncWriteJournal$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.journal.AsyncWriteJournal.Desequenced$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.journal.AsyncWriteProxy$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.journal.AsyncWriteProxy.InitTimeout$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.journal.AsyncWriteProxy.SetStore$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.journal.AsyncWriteTarget$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.journal.AsyncWriteTarget.DeleteMessagesTo$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.journal.AsyncWriteTarget.ReplayFailure$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.journal.AsyncWriteTarget.ReplayMessages$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.journal.AsyncWriteTarget.ReplaySuccess$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.journal.AsyncWriteTarget.WriteMessages$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.journal.EmptyEventSeq$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.journal.EventAdapters$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.journal.EventAdapters.CombinedReadEventAdapter$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.journal.EventSeq$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.journal.EventsSeq$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.journal.IdentityEventAdapter$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.journal.IdentityEventAdapters$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.journal.leveldb.Key$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.journal.leveldb.LeveldbJournal$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.journal.leveldb.LeveldbJournal.CurrentPersistenceIds$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.journal.leveldb.LeveldbJournal.EventAppended$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.journal.leveldb.LeveldbJournal.PersistenceIdAdded$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.journal.leveldb.LeveldbJournal.ReplayedTaggedMessage$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.journal.leveldb.LeveldbJournal.ReplayTaggedMessages$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.journal.leveldb.LeveldbJournal.SubscribeAllPersistenceIds$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.journal.leveldb.LeveldbJournal.SubscribePersistenceId$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.journal.leveldb.LeveldbJournal.SubscribeTag$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.journal.leveldb.LeveldbJournal.TaggedEventAppended$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.journal.leveldb.SharedLeveldbJournal$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.journal.NoopReadEventAdapter$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.journal.NoopWriteEventAdapter$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.journal.ReplayFilter$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.journal.ReplayFilter.Disabled$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.journal.ReplayFilter.Fail$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.journal.ReplayFilter.RepairByDiscardOld$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.journal.ReplayFilter.Warn$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.journal.SingleEventSeq$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.journal.Tagged$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.JournalProtocol$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.JournalProtocol.DeleteMessagesTo$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.JournalProtocol.LoopMessageSuccess$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.JournalProtocol.RecoverySuccess$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.JournalProtocol.ReplayedMessage$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.JournalProtocol.ReplayMessages$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.JournalProtocol.ReplayMessagesFailure$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.JournalProtocol.WriteMessageFailure$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.JournalProtocol.WriteMessageRejected$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.JournalProtocol.WriteMessages$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.JournalProtocol.WriteMessagesFailed$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.JournalProtocol.WriteMessagesSuccessful$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.JournalProtocol.WriteMessageSuccess$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.NonPersistentRepr$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.Persistence$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.Persistence.PluginHolder$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.PersistentImpl$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.PersistentRepr$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.PersistentView$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.PersistentView.ScheduledUpdate$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.Protocol$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.Recovery$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.RecoveryCompleted$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.SaveSnapshotFailure$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.SaveSnapshotSuccess$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.SelectedSnapshot$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.serialization.Snapshot$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.serialization.SnapshotHeader$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.serialization.SnapshotSerializer$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.SnapshotMetadata$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.SnapshotOffer$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.SnapshotProtocol$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.SnapshotProtocol.DeleteSnapshot$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.SnapshotProtocol.DeleteSnapshots$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.SnapshotProtocol.LoadSnapshot$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.SnapshotProtocol.LoadSnapshotResult$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.SnapshotProtocol.SaveSnapshot$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.SnapshotSelectionCriteria$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.Update$
-
Static reference to the singleton instance of this Scala object.
- msg() - Method in class akka.persistence.fsm.PersistentFSM.Timer
-
- msg() - Method in class akka.persistence.journal.AsyncWriteJournal.Desequenced
-
- parseDelimitedFrom(InputStream) - Static method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot
-
- parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot
-
- parseDelimitedFrom(InputStream) - Static method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery
-
- parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery
-
- parseDelimitedFrom(InputStream) - Static method in class akka.persistence.serialization.MessageFormats.AtomicWrite
-
- parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class akka.persistence.serialization.MessageFormats.AtomicWrite
-
- parseDelimitedFrom(InputStream) - Static method in class akka.persistence.serialization.MessageFormats.PersistentMessage
-
- parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class akka.persistence.serialization.MessageFormats.PersistentMessage
-
- parseDelimitedFrom(InputStream) - Static method in class akka.persistence.serialization.MessageFormats.PersistentPayload
-
- parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class akka.persistence.serialization.MessageFormats.PersistentPayload
-
- parseDelimitedFrom(InputStream) - Static method in class akka.persistence.serialization.MessageFormats.PersistentStateChangeEvent
-
- parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class akka.persistence.serialization.MessageFormats.PersistentStateChangeEvent
-
- parseFrom(ByteString) - Static method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot
-
- parseFrom(ByteString, ExtensionRegistryLite) - Static method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot
-
- parseFrom(byte[]) - Static method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot
-
- parseFrom(byte[], ExtensionRegistryLite) - Static method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot
-
- parseFrom(InputStream) - Static method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot
-
- parseFrom(InputStream, ExtensionRegistryLite) - Static method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot
-
- parseFrom(CodedInputStream) - Static method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot
-
- parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot
-
- parseFrom(ByteString) - Static method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery
-
- parseFrom(ByteString, ExtensionRegistryLite) - Static method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery
-
- parseFrom(byte[]) - Static method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery
-
- parseFrom(byte[], ExtensionRegistryLite) - Static method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery
-
- parseFrom(InputStream) - Static method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery
-
- parseFrom(InputStream, ExtensionRegistryLite) - Static method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery
-
- parseFrom(CodedInputStream) - Static method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery
-
- parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery
-
- parseFrom(ByteString) - Static method in class akka.persistence.serialization.MessageFormats.AtomicWrite
-
- parseFrom(ByteString, ExtensionRegistryLite) - Static method in class akka.persistence.serialization.MessageFormats.AtomicWrite
-
- parseFrom(byte[]) - Static method in class akka.persistence.serialization.MessageFormats.AtomicWrite
-
- parseFrom(byte[], ExtensionRegistryLite) - Static method in class akka.persistence.serialization.MessageFormats.AtomicWrite
-
- parseFrom(InputStream) - Static method in class akka.persistence.serialization.MessageFormats.AtomicWrite
-
- parseFrom(InputStream, ExtensionRegistryLite) - Static method in class akka.persistence.serialization.MessageFormats.AtomicWrite
-
- parseFrom(CodedInputStream) - Static method in class akka.persistence.serialization.MessageFormats.AtomicWrite
-
- parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class akka.persistence.serialization.MessageFormats.AtomicWrite
-
- parseFrom(ByteString) - Static method in class akka.persistence.serialization.MessageFormats.PersistentMessage
-
- parseFrom(ByteString, ExtensionRegistryLite) - Static method in class akka.persistence.serialization.MessageFormats.PersistentMessage
-
- parseFrom(byte[]) - Static method in class akka.persistence.serialization.MessageFormats.PersistentMessage
-
- parseFrom(byte[], ExtensionRegistryLite) - Static method in class akka.persistence.serialization.MessageFormats.PersistentMessage
-
- parseFrom(InputStream) - Static method in class akka.persistence.serialization.MessageFormats.PersistentMessage
-
- parseFrom(InputStream, ExtensionRegistryLite) - Static method in class akka.persistence.serialization.MessageFormats.PersistentMessage
-
- parseFrom(CodedInputStream) - Static method in class akka.persistence.serialization.MessageFormats.PersistentMessage
-
- parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class akka.persistence.serialization.MessageFormats.PersistentMessage
-
- parseFrom(ByteString) - Static method in class akka.persistence.serialization.MessageFormats.PersistentPayload
-
- parseFrom(ByteString, ExtensionRegistryLite) - Static method in class akka.persistence.serialization.MessageFormats.PersistentPayload
-
- parseFrom(byte[]) - Static method in class akka.persistence.serialization.MessageFormats.PersistentPayload
-
- parseFrom(byte[], ExtensionRegistryLite) - Static method in class akka.persistence.serialization.MessageFormats.PersistentPayload
-
- parseFrom(InputStream) - Static method in class akka.persistence.serialization.MessageFormats.PersistentPayload
-
- parseFrom(InputStream, ExtensionRegistryLite) - Static method in class akka.persistence.serialization.MessageFormats.PersistentPayload
-
- parseFrom(CodedInputStream) - Static method in class akka.persistence.serialization.MessageFormats.PersistentPayload
-
- parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class akka.persistence.serialization.MessageFormats.PersistentPayload
-
- parseFrom(ByteString) - Static method in class akka.persistence.serialization.MessageFormats.PersistentStateChangeEvent
-
- parseFrom(ByteString, ExtensionRegistryLite) - Static method in class akka.persistence.serialization.MessageFormats.PersistentStateChangeEvent
-
- parseFrom(byte[]) - Static method in class akka.persistence.serialization.MessageFormats.PersistentStateChangeEvent
-
- parseFrom(byte[], ExtensionRegistryLite) - Static method in class akka.persistence.serialization.MessageFormats.PersistentStateChangeEvent
-
- parseFrom(InputStream) - Static method in class akka.persistence.serialization.MessageFormats.PersistentStateChangeEvent
-
- parseFrom(InputStream, ExtensionRegistryLite) - Static method in class akka.persistence.serialization.MessageFormats.PersistentStateChangeEvent
-
- parseFrom(CodedInputStream) - Static method in class akka.persistence.serialization.MessageFormats.PersistentStateChangeEvent
-
- parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class akka.persistence.serialization.MessageFormats.PersistentStateChangeEvent
-
- PARSER - Static variable in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot
-
- PARSER - Static variable in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery
-
- PARSER - Static variable in class akka.persistence.serialization.MessageFormats.AtomicWrite
-
- PARSER - Static variable in class akka.persistence.serialization.MessageFormats.PersistentMessage
-
- PARSER - Static variable in class akka.persistence.serialization.MessageFormats.PersistentPayload
-
- PARSER - Static variable in class akka.persistence.serialization.MessageFormats.PersistentStateChangeEvent
-
- payload() - Method in class akka.persistence.AtomicWrite
-
- payload() - Method in class akka.persistence.journal.Tagged
-
- payload() - Method in class akka.persistence.NonPersistentRepr
-
- payload() - Method in interface akka.persistence.PersistentEnvelope
-
- payload() - Method in class akka.persistence.PersistentImpl
-
- payload() - Method in interface akka.persistence.PersistentRepr
-
This persistent message's payload.
- PAYLOAD_FIELD_NUMBER - Static variable in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery
-
- PAYLOAD_FIELD_NUMBER - Static variable in class akka.persistence.serialization.MessageFormats.AtomicWrite
-
- PAYLOAD_FIELD_NUMBER - Static variable in class akka.persistence.serialization.MessageFormats.PersistentMessage
-
- PAYLOAD_FIELD_NUMBER - Static variable in class akka.persistence.serialization.MessageFormats.PersistentPayload
-
- PAYLOADMANIFEST_FIELD_NUMBER - Static variable in class akka.persistence.serialization.MessageFormats.PersistentPayload
-
- peekApplyHandler(Object) - Method in interface akka.persistence.Eventsourced
-
- pendingInvocations() - Method in interface akka.persistence.Eventsourced
-
- pendingStashingPersistInvocations() - Method in interface akka.persistence.Eventsourced
-
- persist(A, Procedure<A>) - Method in class akka.persistence.AbstractPersistentActor
-
Java API: asynchronously persists event
.
- persist(Iterable<A>, Procedure<A>) - Method in class akka.persistence.AbstractPersistentActor
-
- persist(A, Function1<A, BoxedUnit>) - Method in interface akka.persistence.Eventsourced
-
Asynchronously persists event
.
- persist(Seq<A>, Function1<A, BoxedUnit>) - Method in interface akka.persistence.Eventsourced
-
- persist(A, Procedure<A>) - Method in class akka.persistence.UntypedPersistentActor
-
Java API: asynchronously persists event
.
- persist(Iterable<A>, Procedure<A>) - Method in class akka.persistence.UntypedPersistentActor
-
- persistAll(Iterable<A>, Procedure<A>) - Method in class akka.persistence.AbstractPersistentActor
-
Java API: asynchronously persists events
in specified order.
- persistAll(Seq<A>, Function1<A, BoxedUnit>) - Method in interface akka.persistence.Eventsourced
-
Asynchronously persists events
in specified order.
- persistAll(Iterable<A>, Procedure<A>) - Method in class akka.persistence.UntypedPersistentActor
-
Java API: asynchronously persists events
in specified order.
- persistAllAsync(Iterable<A>, Procedure<A>) - Method in class akka.persistence.AbstractPersistentActor
-
Java API: asynchronously persists events
in specified order.
- persistAllAsync(Seq<A>, Function1<A, BoxedUnit>) - Method in interface akka.persistence.Eventsourced
-
Asynchronously persists events
in specified order.
- persistAllAsync(Iterable<A>, Procedure<A>) - Method in class akka.persistence.UntypedPersistentActor
-
JAVA API: asynchronously persists events
in specified order.
- persistAsync(A, Procedure<A>) - Method in class akka.persistence.AbstractPersistentActor
-
Java API: asynchronously persists event
.
- persistAsync(Iterable<A>, Procedure<A>) - Method in class akka.persistence.AbstractPersistentActor
-
- persistAsync(A, Function1<A, BoxedUnit>) - Method in interface akka.persistence.Eventsourced
-
Asynchronously persists event
.
- persistAsync(Seq<A>, Function1<A, BoxedUnit>) - Method in interface akka.persistence.Eventsourced
-
- persistAsync(A, Procedure<A>) - Method in class akka.persistence.UntypedPersistentActor
-
JAVA API: asynchronously persists event
.
- persistence() - Method in interface akka.persistence.journal.WriteJournalBase
-
- Persistence - Class in akka.persistence
-
Persistence extension.
- Persistence(ExtendedActorSystem) - Constructor for class akka.persistence.Persistence
-
- Persistence$ - Class in akka.persistence
-
Persistence extension provider.
- Persistence$() - Constructor for class akka.persistence.Persistence$
-
- Persistence.PluginHolder - Class in akka.persistence
-
INTERNAL API.
- Persistence.PluginHolder$ - Class in akka.persistence
-
- persistenceId() - Method in class akka.persistence.AtomicWrite
-
- persistenceId() - Method in class akka.persistence.journal.AsyncWriteTarget.DeleteMessagesTo
-
- persistenceId() - Method in class akka.persistence.journal.AsyncWriteTarget.ReplayMessages
-
- persistenceId() - Method in class akka.persistence.journal.leveldb.Key
-
- persistenceId() - Method in class akka.persistence.journal.leveldb.LeveldbJournal.EventAppended
-
- persistenceId() - Method in class akka.persistence.journal.leveldb.LeveldbJournal.PersistenceIdAdded
-
- persistenceId() - Method in class akka.persistence.journal.leveldb.LeveldbJournal.SubscribePersistenceId
-
- persistenceId() - Method in class akka.persistence.JournalProtocol.DeleteMessagesTo
-
- persistenceId() - Method in class akka.persistence.JournalProtocol.ReplayMessages
-
- persistenceId(ActorRef) - Method in class akka.persistence.Persistence
-
Creates a canonical persistent actor id from a persistent actor ref.
- persistenceId() - Method in interface akka.persistence.PersistenceIdentity
-
Id of the persistent entity for which messages should be replayed.
- persistenceId() - Method in class akka.persistence.PersistentImpl
-
- persistenceId() - Method in interface akka.persistence.PersistentRepr
-
Persistent id that journals a persistent message
- persistenceId() - Method in class akka.persistence.SnapshotMetadata
-
- persistenceId() - Method in class akka.persistence.SnapshotProtocol.DeleteSnapshots
-
- persistenceId() - Method in class akka.persistence.SnapshotProtocol.LoadSnapshot
-
- PERSISTENCEID_FIELD_NUMBER - Static variable in class akka.persistence.serialization.MessageFormats.PersistentMessage
-
- PersistenceIdAdded(String) - Constructor for class akka.persistence.journal.leveldb.LeveldbJournal.PersistenceIdAdded
-
- PersistenceIdAdded$() - Constructor for class akka.persistence.journal.leveldb.LeveldbJournal.PersistenceIdAdded$
-
- PersistenceIdentity - Interface in akka.persistence
-
- persistenceIdSubscribers() - Method in interface akka.persistence.journal.leveldb.LeveldbStore
-
- PersistenceRecovery - Interface in akka.persistence
-
- PersistenceSettings - Class in akka.persistence
-
Persistence configuration.
- PersistenceSettings(Config) - Constructor for class akka.persistence.PersistenceSettings
-
- PersistenceSettings.atLeastOnceDelivery - Class in akka.persistence
-
- PersistenceSettings.internal - Class in akka.persistence
-
INTERNAL API.
- PersistenceSettings.view - Class in akka.persistence
-
- persistent() - Method in class akka.persistence.journal.leveldb.LeveldbJournal.ReplayedTaggedMessage
-
- persistent() - Method in class akka.persistence.JournalProtocol.ReplayedMessage
-
- persistent() - Method in class akka.persistence.JournalProtocol.WriteMessageSuccess
-
- persistentActor() - Method in class akka.persistence.JournalProtocol.DeleteMessagesTo
-
- persistentActor() - Method in class akka.persistence.JournalProtocol.ReplayMessages
-
- persistentActor() - Method in class akka.persistence.JournalProtocol.WriteMessages
-
- PersistentActor - Interface in akka.persistence
-
An persistent Actor - can be used to implement command or event sourcing.
- PersistentEnvelope - Interface in akka.persistence
-
INTERNAL API
- persistentFromBytes(byte[]) - Method in interface akka.persistence.journal.leveldb.LeveldbStore
-
- PersistentFSM<S extends PersistentFSM.FSMState,D,E> - Interface in akka.persistence.fsm
-
A FSM implementation with persistent state.
- PersistentFSM$ - Class in akka.persistence.fsm
-
- PersistentFSM$() - Constructor for class akka.persistence.fsm.PersistentFSM$
-
- PersistentFSM.$minus$greater$ - Class in akka.persistence.fsm
-
This extractor is just convenience for matching a (S, S) pair, including a
reminder what the new state is.
- PersistentFSM.CurrentState<S> - Class in akka.persistence.fsm
-
Message type which is sent directly to the subscribed actor in
FSM.SubscribeTransitionCallBack
before sending any
FSM.Transition
messages.
- PersistentFSM.CurrentState$ - Class in akka.persistence.fsm
-
- PersistentFSM.Event<D> - Class in akka.persistence.fsm
-
All messages sent to the FSM
will be wrapped inside an
Event
, which allows pattern matching to extract both state and data.
- PersistentFSM.Event$ - Class in akka.persistence.fsm
-
- PersistentFSM.Failure - Class in akka.persistence.fsm
-
Signifies that the FSM
is shutting itself down because of
an error, e.g.
- PersistentFSM.Failure$ - Class in akka.persistence.fsm
-
- PersistentFSM.FSMState - Interface in akka.persistence.fsm
-
FSMState base trait, makes possible for simple default serialization by conversion to String
- PersistentFSM.LogEntry<S,D> - Class in akka.persistence.fsm
-
Log Entry of the LoggingFSM
, can be obtained by calling getLog
.
- PersistentFSM.LogEntry$ - Class in akka.persistence.fsm
-
- PersistentFSM.Normal$ - Class in akka.persistence.fsm
-
Default reason if calling stop()
.
- PersistentFSM.NullFunction$ - Class in akka.persistence.fsm
-
A partial function value which does not match anything and can be used to
“reset” whenUnhandled
and onTermination
handlers.
- PersistentFSM.PersistentFsmEvent - Interface in akka.persistence.fsm
-
Base persistent event class
- PersistentFSM.Reason - Interface in akka.persistence.fsm
-
Reason why this FSM
is shutting down.
- PersistentFSM.Shutdown$ - Class in akka.persistence.fsm
-
Reason given when someone was calling system.stop(fsm)
from outside;
also applies to Stop
supervision directive.
- PersistentFSM.State<S,D,E> - Class in akka.persistence.fsm
-
This captures all of the managed state of the FSM
: the state
name, the state data, possibly custom timeout, stop reason, replies
accumulated while processing the last message, possibly domain event and handler
to be executed after FSM moves to the new state (also triggered when staying in the same state)
- PersistentFSM.State$ - Class in akka.persistence.fsm
-
- PersistentFSM.StateChangeEvent - Class in akka.persistence.fsm
-
Persisted on state change
- PersistentFSM.StateChangeEvent$ - Class in akka.persistence.fsm
-
- PersistentFSM.StateTimeout$ - Class in akka.persistence.fsm
-
This case object is received in case of a state timeout.
- PersistentFSM.StopEvent<S,D> - Class in akka.persistence.fsm
-
Case class representing the state of the FSM
whithin the
onTermination
block.
- PersistentFSM.StopEvent$ - Class in akka.persistence.fsm
-
- PersistentFSM.SubscribeTransitionCallBack - Class in akka.persistence.fsm
-
- PersistentFSM.SubscribeTransitionCallBack$ - Class in akka.persistence.fsm
-
- PersistentFSM.TimeoutMarker - Class in akka.persistence.fsm
-
INTERNAL API
- PersistentFSM.TimeoutMarker$ - Class in akka.persistence.fsm
-
- PersistentFSM.Timer - Class in akka.persistence.fsm
-
INTERNAL API
- PersistentFSM.Timer$ - Class in akka.persistence.fsm
-
- PersistentFSM.Transition<S> - Class in akka.persistence.fsm
-
Message type which is used to communicate transitions between states to
all subscribed listeners (use FSM.SubscribeTransitionCallBack
).
- PersistentFSM.Transition$ - Class in akka.persistence.fsm
-
- PersistentFSM.UnsubscribeTransitionCallBack - Class in akka.persistence.fsm
-
Unsubscribe from FSM.Transition
notifications which was
effected by sending the corresponding FSM.SubscribeTransitionCallBack
.
- PersistentFSM.UnsubscribeTransitionCallBack$ - Class in akka.persistence.fsm
-
- PersistentFSMBase<S,D,E> - Interface in akka.persistence.fsm
-
Finite State Machine actor trait.
- PersistentFSMBase.TransformHelper - Class in akka.persistence.fsm
-
- PersistentImpl - Class in akka.persistence
-
INTERNAL API.
- PersistentImpl(Object, long, String, String, boolean, ActorRef, String) - Constructor for class akka.persistence.PersistentImpl
-
- PersistentImpl$ - Class in akka.persistence
-
- PersistentImpl$() - Constructor for class akka.persistence.PersistentImpl$
-
- PersistentImplClass() - Method in class akka.persistence.serialization.MessageSerializer
-
- PersistentRepr - Interface in akka.persistence
-
Plugin API: representation of a persistent message in the journal plugin API.
- PersistentRepr$ - Class in akka.persistence
-
- PersistentRepr$() - Constructor for class akka.persistence.PersistentRepr$
-
- PersistentReprClass() - Method in class akka.persistence.serialization.MessageSerializer
-
- PersistentStateChangeEventClass() - Method in class akka.persistence.serialization.MessageSerializer
-
- persistentToBytes(PersistentRepr) - Method in interface akka.persistence.journal.leveldb.LeveldbStore
-
- PersistentView - Interface in akka.persistence
-
- PersistentView$ - Class in akka.persistence
-
INTERNAL API
- PersistentView$() - Constructor for class akka.persistence.PersistentView$
-
- PersistentView.ScheduledUpdate - Class in akka.persistence
-
- PersistentView.ScheduledUpdate$ - Class in akka.persistence
-
- PersistentView.State - Interface in akka.persistence
-
- persistingEvents() - Method in interface akka.persistence.Eventsourced
-
Event persisting state.
- PluginHolder(ActorRef, EventAdapters, Config) - Constructor for class akka.persistence.Persistence.PluginHolder
-
- PluginHolder$() - Constructor for class akka.persistence.Persistence.PluginHolder$
-
- pos() - Method in interface akka.persistence.fsm.LoggingPersistentFSM
-
- postStop() - Method in interface akka.persistence.fsm.PersistentFSMBase
-
- postStop() - Method in interface akka.persistence.journal.leveldb.LeveldbStore
-
- postStop() - Method in interface akka.persistence.PersistentView
-
- preparePersistentBatch(Seq<PersistentEnvelope>) - Method in interface akka.persistence.journal.WriteJournalBase
-
- preRestart(Throwable, Option<Object>) - Method in interface akka.persistence.PersistentView
-
- preStart() - Method in class akka.persistence.journal.inmem.InmemJournal
-
- preStart() - Method in interface akka.persistence.journal.leveldb.LeveldbIdMapping
-
- preStart() - Method in interface akka.persistence.journal.leveldb.LeveldbStore
-
- preStart() - Method in interface akka.persistence.PersistentView
-
Triggers an initial recovery, starting form a snapshot, if any, and replaying at most autoUpdateReplayMax
messages (following that snapshot).
- preStart() - Method in class akka.persistence.snapshot.local.LocalSnapshotStore
-
- processEvent(PersistentFSM.Event<D>, Object) - Method in interface akka.persistence.fsm.LoggingPersistentFSM
-
- processEvent(PersistentFSM.Event<D>, Object) - Method in interface akka.persistence.fsm.PersistentFSMBase
-
- processingCommands() - Method in interface akka.persistence.Eventsourced
-
Command processing state.
- ProcessingState() - Constructor for class akka.persistence.Eventsourced.ProcessingState
-
- processMsg(Object, Object) - Method in interface akka.persistence.fsm.PersistentFSMBase
-
- props(ActorRef, ReplayFilter.Mode, int, int) - Method in class akka.persistence.journal.ReplayFilter$
-
- props(ActorRef, ReplayFilter.Mode, int, int) - Static method in class akka.persistence.journal.ReplayFilter
-
- Protocol - Class in akka.persistence
-
INTERNAL API.
- Protocol() - Constructor for class akka.persistence.Protocol
-
- Protocol$ - Class in akka.persistence
-
INTERNAL API.
- Protocol$() - Constructor for class akka.persistence.Protocol$
-
- Protocol.Message - Interface in akka.persistence
-
INTERNAL API.
- publish() - Method in interface akka.persistence.journal.AsyncWriteJournal
-
- publish() - Method in interface akka.persistence.snapshot.SnapshotStore
-
- publishPluginCommands() - Method in class akka.persistence.PersistenceSettings.internal
-
- safeLongToInt(long) - Method in interface akka.persistence.journal.inmem.InmemMessages
-
- save(SnapshotMetadata, Object) - Method in class akka.persistence.snapshot.local.LocalSnapshotStore
-
- saveAsync(SnapshotMetadata, Object) - Method in class akka.persistence.snapshot.japi.SnapshotStore
-
- saveAsync(SnapshotMetadata, Object) - Method in class akka.persistence.snapshot.local.LocalSnapshotStore
-
- saveAsync(SnapshotMetadata, Object) - Method in class akka.persistence.snapshot.NoSnapshotStore
-
- saveAsync(SnapshotMetadata, Object) - Method in interface akka.persistence.snapshot.SnapshotStore
-
Plugin API: asynchronously saves a snapshot.
- SaveSnapshot(SnapshotMetadata, Object) - Constructor for class akka.persistence.SnapshotProtocol.SaveSnapshot
-
- saveSnapshot(Object) - Method in interface akka.persistence.Snapshotter
-
Saves a snapshot
of this snapshotter's state.
- SaveSnapshot$() - Constructor for class akka.persistence.SnapshotProtocol.SaveSnapshot$
-
- SaveSnapshotFailure - Class in akka.persistence
-
- SaveSnapshotFailure(SnapshotMetadata, Throwable) - Constructor for class akka.persistence.SaveSnapshotFailure
-
- SaveSnapshotFailure$ - Class in akka.persistence
-
- SaveSnapshotFailure$() - Constructor for class akka.persistence.SaveSnapshotFailure$
-
- SaveSnapshotSuccess - Class in akka.persistence
-
- SaveSnapshotSuccess(SnapshotMetadata) - Constructor for class akka.persistence.SaveSnapshotSuccess
-
- SaveSnapshotSuccess$ - Class in akka.persistence
-
- SaveSnapshotSuccess$() - Constructor for class akka.persistence.SaveSnapshotSuccess$
-
- schedule(ActorRef, FiniteDuration) - Method in class akka.persistence.fsm.PersistentFSM.Timer
-
- schedule() - Method in interface akka.persistence.PersistentView
-
- ScheduledUpdate(long) - Constructor for class akka.persistence.PersistentView.ScheduledUpdate
-
- ScheduledUpdate$() - Constructor for class akka.persistence.PersistentView.ScheduledUpdate$
-
- SelectedSnapshot - Class in akka.persistence
-
- SelectedSnapshot(SnapshotMetadata, Object) - Constructor for class akka.persistence.SelectedSnapshot
-
- SelectedSnapshot$ - Class in akka.persistence
-
- SelectedSnapshot$() - Constructor for class akka.persistence.SelectedSnapshot$
-
- send(long, akka.persistence.AtLeastOnceDelivery.Internal.Delivery, long) - Method in interface akka.persistence.AtLeastOnceDeliveryLike
-
- sendBuffered() - Method in class akka.persistence.journal.ReplayFilter
-
- sender() - Method in class akka.persistence.AtomicWrite
-
- sender() - Method in class akka.persistence.journal.AsyncWriteJournal.Desequenced
-
- sender() - Method in class akka.persistence.NonPersistentRepr
-
- sender() - Method in interface akka.persistence.PersistentEnvelope
-
- sender() - Method in class akka.persistence.PersistentImpl
-
- sender() - Method in interface akka.persistence.PersistentRepr
-
Sender of this message.
- SENDER_FIELD_NUMBER - Static variable in class akka.persistence.serialization.MessageFormats.PersistentMessage
-
- senderPersistentActor() - Method in interface akka.persistence.snapshot.SnapshotStore
-
Documents intent that the sender() is expected to be the PersistentActor
- seqNo() - Method in class akka.persistence.journal.ReplayFilter
-
- sequenceNr() - Method in interface akka.persistence.Eventsourced
-
- sequenceNr() - Method in class akka.persistence.journal.leveldb.Key
-
- sequenceNr() - Method in class akka.persistence.PersistentImpl
-
- sequenceNr() - Method in interface akka.persistence.PersistentRepr
-
This persistent message's sequence number.
- sequenceNr() - Method in class akka.persistence.SnapshotMetadata
-
- SEQUENCENR_FIELD_NUMBER - Static variable in class akka.persistence.serialization.MessageFormats.PersistentMessage
-
- serialization() - Method in interface akka.persistence.journal.leveldb.LeveldbStore
-
- serialize(OutputStream, Snapshot) - Method in class akka.persistence.snapshot.local.LocalSnapshotStore
-
- serializerId() - Method in class akka.persistence.serialization.SnapshotHeader
-
- SERIALIZERID_FIELD_NUMBER - Static variable in class akka.persistence.serialization.MessageFormats.PersistentPayload
-
- setCurrentDeliveryId(long) - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.Builder
-
required int64 currentDeliveryId = 1;
- setDeleted(boolean) - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage.Builder
-
optional bool deleted = 4;
- setDeliveryId(long) - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery.Builder
-
required int64 deliveryId = 1;
- setDeliverySnapshot(AtLeastOnceDelivery.AtLeastOnceDeliverySnapshot) - Method in interface akka.persistence.AtLeastOnceDeliveryLike
-
- setDestination(String) - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery.Builder
-
required string destination = 2;
- setDestinationBytes(ByteString) - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery.Builder
-
required string destination = 2;
- setLastSequenceNr(long) - Method in interface akka.persistence.Eventsourced
-
- setLastSequenceNr(long) - Method in interface akka.persistence.PersistentView
-
- setManifest(String) - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage.Builder
-
optional string manifest = 12;
- setManifestBytes(ByteString) - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage.Builder
-
optional string manifest = 12;
- setPayload(MessageFormats.PersistentPayload) - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery.Builder
-
required .PersistentPayload payload = 3;
- setPayload(MessageFormats.PersistentPayload.Builder) - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery.Builder
-
required .PersistentPayload payload = 3;
- setPayload(int, MessageFormats.PersistentMessage) - Method in class akka.persistence.serialization.MessageFormats.AtomicWrite.Builder
-
repeated .PersistentMessage payload = 1;
- setPayload(int, MessageFormats.PersistentMessage.Builder) - Method in class akka.persistence.serialization.MessageFormats.AtomicWrite.Builder
-
repeated .PersistentMessage payload = 1;
- setPayload(MessageFormats.PersistentPayload) - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage.Builder
-
optional .PersistentPayload payload = 1;
- setPayload(MessageFormats.PersistentPayload.Builder) - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage.Builder
-
optional .PersistentPayload payload = 1;
- setPayload(ByteString) - Method in class akka.persistence.serialization.MessageFormats.PersistentPayload.Builder
-
required bytes payload = 2;
- setPayloadManifest(ByteString) - Method in class akka.persistence.serialization.MessageFormats.PersistentPayload.Builder
-
optional bytes payloadManifest = 3;
- setPersistenceId(String) - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage.Builder
-
optional string persistenceId = 3;
- setPersistenceIdBytes(ByteString) - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage.Builder
-
optional string persistenceId = 3;
- setSender(String) - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage.Builder
-
optional string sender = 11;
- setSenderBytes(ByteString) - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage.Builder
-
optional string sender = 11;
- setSequenceNr(long) - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage.Builder
-
optional int64 sequenceNr = 2;
- setSerializerId(int) - Method in class akka.persistence.serialization.MessageFormats.PersistentPayload.Builder
-
required int32 serializerId = 1;
- setStateIdentifier(String) - Method in class akka.persistence.serialization.MessageFormats.PersistentStateChangeEvent.Builder
-
required string stateIdentifier = 1;
- setStateIdentifierBytes(ByteString) - Method in class akka.persistence.serialization.MessageFormats.PersistentStateChangeEvent.Builder
-
required string stateIdentifier = 1;
- setStateTimeout(S, Option<FiniteDuration>) - Method in interface akka.persistence.fsm.PersistentFSMBase
-
- SetStore(ActorRef) - Constructor for class akka.persistence.journal.AsyncWriteProxy.SetStore
-
- setStore(ActorRef, ActorSystem) - Method in class akka.persistence.journal.leveldb.SharedLeveldbJournal$
-
Sets the shared LevelDB store
for the given actor system
.
- setStore(ActorRef, ActorSystem) - Static method in class akka.persistence.journal.leveldb.SharedLeveldbJournal
-
Sets the shared LevelDB store
for the given actor system
.
- SetStore$() - Constructor for class akka.persistence.journal.AsyncWriteProxy.SetStore$
-
- setTimeout(String) - Method in class akka.persistence.serialization.MessageFormats.PersistentStateChangeEvent.Builder
-
optional string timeout = 2;
- setTimeoutBytes(ByteString) - Method in class akka.persistence.serialization.MessageFormats.PersistentStateChangeEvent.Builder
-
optional string timeout = 2;
- setTimer(String, Object, FiniteDuration) - Method in class akka.persistence.fsm.AbstractPersistentFSMBase
-
Schedule named timer to deliver message after given delay, possibly repeating.
- setTimer(String, Object, FiniteDuration, boolean) - Method in interface akka.persistence.fsm.PersistentFSMBase
-
- settings() - Method in class akka.persistence.Persistence
-
- setUnconfirmedDeliveries(int, MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery) - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.Builder
-
repeated .AtLeastOnceDeliverySnapshot.UnconfirmedDelivery unconfirmedDeliveries = 2;
- setUnconfirmedDeliveries(int, MessageFormats.AtLeastOnceDeliverySnapshot.UnconfirmedDelivery.Builder) - Method in class akka.persistence.serialization.MessageFormats.AtLeastOnceDeliverySnapshot.Builder
-
repeated .AtLeastOnceDeliverySnapshot.UnconfirmedDelivery unconfirmedDeliveries = 2;
- setWriterUuid(String) - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage.Builder
-
optional string writerUuid = 13;
- setWriterUuidBytes(ByteString) - Method in class akka.persistence.serialization.MessageFormats.PersistentMessage.Builder
-
optional string writerUuid = 13;
- SharedLeveldbJournal - Class in akka.persistence.journal.leveldb
-
INTERNAL API.
- SharedLeveldbJournal() - Constructor for class akka.persistence.journal.leveldb.SharedLeveldbJournal
-
- SharedLeveldbJournal$ - Class in akka.persistence.journal.leveldb
-
- SharedLeveldbJournal$() - Constructor for class akka.persistence.journal.leveldb.SharedLeveldbJournal$
-
- SharedLeveldbStore - Class in akka.persistence.journal.leveldb
-
A LevelDB store that can be shared by multiple actor systems.
- SharedLeveldbStore() - Constructor for class akka.persistence.journal.leveldb.SharedLeveldbStore
-
- Shutdown() - Method in class akka.persistence.fsm.AbstractPersistentFSMBase
-
Reason given when someone was calling system.stop(fsm)
from outside;
also applies to Stop
supervision directive.
- Shutdown$() - Constructor for class akka.persistence.fsm.PersistentFSM.Shutdown$
-
- single(Object) - Method in class akka.persistence.journal.EventSeq$
-
Java API
- single(Object) - Static method in class akka.persistence.journal.EventSeq
-
Java API
- SingleEventSeq - Class in akka.persistence.journal
-
- SingleEventSeq(Object) - Constructor for class akka.persistence.journal.SingleEventSeq
-
- SingleEventSeq$ - Class in akka.persistence.journal
-
- SingleEventSeq$() - Constructor for class akka.persistence.journal.SingleEventSeq$
-
- size() - Method in class akka.persistence.AtomicWrite
-
- size() - Method in class akka.persistence.NonPersistentRepr
-
- size() - Method in interface akka.persistence.PersistentEnvelope
-
- snapshot() - Method in class akka.persistence.SelectedSnapshot
-
- Snapshot - Class in akka.persistence.serialization
-
Wrapper for snapshot data
.
- Snapshot(Object) - Constructor for class akka.persistence.serialization.Snapshot
-
- snapshot() - Method in class akka.persistence.SnapshotOffer
-
- snapshot() - Method in class akka.persistence.SnapshotProtocol.LoadSnapshotResult
-
- snapshot() - Method in class akka.persistence.SnapshotProtocol.SaveSnapshot
-
- Snapshot$ - Class in akka.persistence.serialization
-
- Snapshot$() - Constructor for class akka.persistence.serialization.Snapshot$
-
- SnapshotHeader - Class in akka.persistence.serialization
-
INTERNAL API.
- SnapshotHeader(int, Option<String>) - Constructor for class akka.persistence.serialization.SnapshotHeader
-
- SnapshotHeader$ - Class in akka.persistence.serialization
-
- SnapshotHeader$() - Constructor for class akka.persistence.serialization.SnapshotHeader$
-
- SnapshotMetadata - Class in akka.persistence
-
Snapshot metadata.
- SnapshotMetadata(String, long, long) - Constructor for class akka.persistence.SnapshotMetadata
-
- SnapshotMetadata$ - Class in akka.persistence
-
- SnapshotMetadata$() - Constructor for class akka.persistence.SnapshotMetadata$
-
- SnapshotOffer - Class in akka.persistence
-
- SnapshotOffer(SnapshotMetadata, Object) - Constructor for class akka.persistence.SnapshotOffer
-
- SnapshotOffer$ - Class in akka.persistence
-
- SnapshotOffer$() - Constructor for class akka.persistence.SnapshotOffer$
-
- snapshotPluginId() - Method in interface akka.persistence.PersistenceIdentity
-
Configuration id of the snapshot plugin servicing this persistent actor or view.
- SnapshotProtocol - Class in akka.persistence
-
INTERNAL API.
- SnapshotProtocol() - Constructor for class akka.persistence.SnapshotProtocol
-
- SnapshotProtocol$ - Class in akka.persistence
-
INTERNAL API.
- SnapshotProtocol$() - Constructor for class akka.persistence.SnapshotProtocol$
-
- SnapshotProtocol.DeleteSnapshot - Class in akka.persistence
-
Instructs snapshot store to delete a snapshot.
- SnapshotProtocol.DeleteSnapshot$ - Class in akka.persistence
-
- SnapshotProtocol.DeleteSnapshots - Class in akka.persistence
-
Instructs snapshot store to delete all snapshots that match criteria
.
- SnapshotProtocol.DeleteSnapshots$ - Class in akka.persistence
-
- SnapshotProtocol.LoadSnapshot - Class in akka.persistence
-
Instructs a snapshot store to load a snapshot.
- SnapshotProtocol.LoadSnapshot$ - Class in akka.persistence
-
- SnapshotProtocol.LoadSnapshotResult - Class in akka.persistence
-
- SnapshotProtocol.LoadSnapshotResult$ - Class in akka.persistence
-
- SnapshotProtocol.Message - Interface in akka.persistence
-
Marker trait shared by internal snapshot messages.
- SnapshotProtocol.Request - Interface in akka.persistence
-
Internal snapshot command.
- SnapshotProtocol.Response - Interface in akka.persistence
-
Internal snapshot acknowledgement.
- SnapshotProtocol.SaveSnapshot - Class in akka.persistence
-
Instructs snapshot store to save a snapshot.
- SnapshotProtocol.SaveSnapshot$ - Class in akka.persistence
-
- SnapshotSelectionCriteria - Class in akka.persistence
-
Selection criteria for loading and deleting snapshots.
- SnapshotSelectionCriteria(long, long, long, long) - Constructor for class akka.persistence.SnapshotSelectionCriteria
-
- SnapshotSelectionCriteria$ - Class in akka.persistence
-
- SnapshotSelectionCriteria$() - Constructor for class akka.persistence.SnapshotSelectionCriteria$
-
- snapshotSequenceNr() - Method in interface akka.persistence.Eventsourced
-
Returns lastSequenceNr
.
- snapshotSequenceNr() - Method in interface akka.persistence.PersistentView
-
Returns lastSequenceNr
.
- snapshotSequenceNr() - Method in interface akka.persistence.Snapshotter
-
Sequence number to use when taking a snapshot.
- SnapshotSerializer - Class in akka.persistence.serialization
-
- SnapshotSerializer(ExtendedActorSystem) - Constructor for class akka.persistence.serialization.SnapshotSerializer
-
- SnapshotSerializer$ - Class in akka.persistence.serialization
-
- SnapshotSerializer$() - Constructor for class akka.persistence.serialization.SnapshotSerializer$
-
- snapshotStore() - Method in interface akka.persistence.Eventsourced
-
- snapshotStore() - Method in interface akka.persistence.PersistentView
-
- SnapshotStore - Class in akka.persistence.snapshot.japi
-
Java API: abstract snapshot store.
- SnapshotStore() - Constructor for class akka.persistence.snapshot.japi.SnapshotStore
-
- SnapshotStore - Interface in akka.persistence.snapshot
-
Abstract snapshot store.
- snapshotStore() - Method in interface akka.persistence.Snapshotter
-
Snapshot store plugin actor.
- snapshotStoreFor(String) - Method in class akka.persistence.Persistence
-
INTERNAL API
- Snapshotter - Interface in akka.persistence
-
Snapshot API on top of the internal snapshot protocol.
- snapshotterId() - Method in interface akka.persistence.Eventsourced
-
Returns persistenceId
.
- snapshotterId() - Method in interface akka.persistence.PersistentView
-
Returns viewId
.
- snapshotterId() - Method in interface akka.persistence.Snapshotter
-
Snapshotter id.
- snr() - Method in class akka.persistence.journal.AsyncWriteJournal.Desequenced
-
- startRecovery(Recovery) - Method in interface akka.persistence.Eventsourced
-
- startRecovery(Recovery) - Method in interface akka.persistence.PersistentView
-
- startRedeliverTask() - Method in interface akka.persistence.AtLeastOnceDeliveryLike
-
- startWith(S, D) - Method in class akka.persistence.fsm.AbstractPersistentFSMBase
-
Set initial state.
- startWith(S, D, FiniteDuration) - Method in class akka.persistence.fsm.AbstractPersistentFSMBase
-
Set initial state.
- startWith(S, D, Option<FiniteDuration>) - Method in interface akka.persistence.fsm.PersistentFSMBase
-
Set initial state.
- StashingHandlerInvocation(Object, Function1<Object, BoxedUnit>) - Constructor for class akka.persistence.Eventsourced.StashingHandlerInvocation
-
- StashingHandlerInvocation$() - Constructor for class akka.persistence.Eventsourced.StashingHandlerInvocation$
-
- state() - Method in class akka.persistence.fsm.PersistentFSM.CurrentState
-
- State(S, D, Option<FiniteDuration>, Option<PersistentFSM.Reason>, List<Object>, Seq<E>, Function1<D, BoxedUnit>, boolean) - Constructor for class akka.persistence.fsm.PersistentFSM.State
-
- State$() - Constructor for class akka.persistence.fsm.PersistentFSM.State$
-
- stateChange(MessageFormats.PersistentStateChangeEvent) - Method in class akka.persistence.serialization.MessageSerializer
-
- stateChangeBuilder(PersistentFSM.StateChangeEvent) - Method in class akka.persistence.serialization.MessageSerializer
-
- StateChangeEvent(String, Option<FiniteDuration>) - Constructor for class akka.persistence.fsm.PersistentFSM.StateChangeEvent
-
- StateChangeEvent$() - Constructor for class akka.persistence.fsm.PersistentFSM.StateChangeEvent$
-
- stateData() - Method in class akka.persistence.fsm.PersistentFSM.Event
-
- stateData() - Method in class akka.persistence.fsm.PersistentFSM.LogEntry
-
- stateData() - Method in class akka.persistence.fsm.PersistentFSM.State
-
- stateData() - Method in class akka.persistence.fsm.PersistentFSM.StopEvent
-
- stateData() - Method in interface akka.persistence.fsm.PersistentFSMBase
-
- stateFunctions() - Method in interface akka.persistence.fsm.PersistentFSMBase
-
- stateIdentifier() - Method in class akka.persistence.fsm.PersistentFSM.StateChangeEvent
-
- STATEIDENTIFIER_FIELD_NUMBER - Static variable in class akka.persistence.serialization.MessageFormats.PersistentStateChangeEvent
-
- stateName() - Method in class akka.persistence.fsm.PersistentFSM.LogEntry
-
- stateName() - Method in class akka.persistence.fsm.PersistentFSM.State
-
- stateName() - Method in interface akka.persistence.fsm.PersistentFSMBase
-
- stateNames() - Method in interface akka.persistence.fsm.PersistentFSMBase
-
- stateReceive(PartialFunction<Object, BoxedUnit>, Object) - Method in interface akka.persistence.Eventsourced.State
-
- stateReceive(PartialFunction<Object, BoxedUnit>, Object) - Method in interface akka.persistence.PersistentView.State
-
- states() - Method in interface akka.persistence.fsm.LoggingPersistentFSM
-
- statesMap() - Method in interface akka.persistence.fsm.PersistentFSM
-
Map from state identifier to state instance
- StateTimeout() - Method in interface akka.persistence.fsm.PersistentFSMBase
-
This case object is received in case of a state timeout.
- StateTimeout$() - Constructor for class akka.persistence.fsm.PersistentFSM.StateTimeout$
-
- stateTimeouts() - Method in interface akka.persistence.fsm.PersistentFSMBase
-
- stay() - Method in interface akka.persistence.fsm.PersistentFSMBase
-
Produce "empty" transition descriptor.
- stop(PersistentFSM.Reason, FI.UnitApply2<S, D>) - Method in class akka.persistence.fsm.japi.pf.FSMStopBuilder
-
Add a case statement that matches on an FSM.Reason
.
- stop(Class<P>, FI.UnitApply3<P, S, D>) - Method in class akka.persistence.fsm.japi.pf.FSMStopBuilder
-
Add a case statement that matches on a reason type.
- stop(Class<P>, FI.TypedPredicate<P>, FI.UnitApply3<P, S, D>) - Method in class akka.persistence.fsm.japi.pf.FSMStopBuilder
-
Add a case statement that matches on a reason type and a predicate.
- stop() - Method in interface akka.persistence.fsm.PersistentFSMBase
-
Produce change descriptor to stop this FSM actor with reason "Normal".
- stop(PersistentFSM.Reason) - Method in interface akka.persistence.fsm.PersistentFSMBase
-
Produce change descriptor to stop this FSM actor including specified reason.
- stop(PersistentFSM.Reason, D) - Method in interface akka.persistence.fsm.PersistentFSMBase
-
Produce change descriptor to stop this FSM actor including specified reason.
- StopEvent(PersistentFSM.Reason, S, D) - Constructor for class akka.persistence.fsm.PersistentFSM.StopEvent
-
- StopEvent() - Method in interface akka.persistence.fsm.PersistentFSMBase
-
- StopEvent$() - Constructor for class akka.persistence.fsm.PersistentFSM.StopEvent$
-
- stopReason() - Method in class akka.persistence.fsm.PersistentFSM.State
-
- store() - Method in interface akka.persistence.journal.AsyncWriteProxy
-
- storeNotInitialized() - Method in interface akka.persistence.journal.AsyncWriteProxy
-
- SubscribeAllPersistenceIds$() - Constructor for class akka.persistence.journal.leveldb.LeveldbJournal.SubscribeAllPersistenceIds$
-
- SubscribePersistenceId(String) - Constructor for class akka.persistence.journal.leveldb.LeveldbJournal.SubscribePersistenceId
-
- SubscribePersistenceId$() - Constructor for class akka.persistence.journal.leveldb.LeveldbJournal.SubscribePersistenceId$
-
- SubscribeTag(String) - Constructor for class akka.persistence.journal.leveldb.LeveldbJournal.SubscribeTag
-
- SubscribeTag$() - Constructor for class akka.persistence.journal.leveldb.LeveldbJournal.SubscribeTag$
-
- SubscribeTransitionCallBack(ActorRef) - Constructor for class akka.persistence.fsm.PersistentFSM.SubscribeTransitionCallBack
-
- SubscribeTransitionCallBack$() - Constructor for class akka.persistence.fsm.PersistentFSM.SubscribeTransitionCallBack$
-
- successUnit() - Method in class akka.persistence.journal.AsyncWriteJournal$
-
- system() - Method in class akka.persistence.Persistence
-
- system() - Method in class akka.persistence.serialization.MessageSerializer
-
- system() - Method in class akka.persistence.serialization.SnapshotSerializer
-