Interface JournalInteractions<C,​E,​S>


  • public interface JournalInteractions<C,​E,​S>
    INTERNAL API
    • Method Detail

      • setup

        akka.persistence.typed.internal.BehaviorSetup<C,​E,​S> setup()
      • internalPersist

        akka.persistence.typed.internal.Running.RunningState<S> internalPersist​(ActorContext<?> ctx,
                                                                                java.lang.Object cmd,
                                                                                akka.persistence.typed.internal.Running.RunningState<S> state,
                                                                                java.lang.Object event,
                                                                                java.lang.String eventAdapterManifest,
                                                                                <any> metadata)
      • internalPersistAll

        akka.persistence.typed.internal.Running.RunningState<S> internalPersistAll​(ActorContext<?> ctx,
                                                                                   java.lang.Object cmd,
                                                                                   akka.persistence.typed.internal.Running.RunningState<S> state,
                                                                                   scala.collection.immutable.Seq<JournalInteractions.EventToPersist> events)
      • onWritesInitiated

        void onWritesInitiated​(ActorContext<?> ctx,
                               java.lang.Object cmd,
                               scala.collection.immutable.Seq<PersistentRepr> repr)
      • replayEvents

        void replayEvents​(long fromSeqNr,
                          long toSeqNr)
      • requestRecoveryPermit

        void requestRecoveryPermit()
      • tryReturnRecoveryPermit

        void tryReturnRecoveryPermit​(java.lang.String reason)
        Mutates setup, by setting the `holdingRecoveryPermit` to false
      • internalDeleteEvents

        void internalDeleteEvents​(long lastSequenceNr,
                                  long toSequenceNr)
        On SaveSnapshotSuccess, if SnapshotCountRetentionCriteria.deleteEventsOnSnapshot is enabled, old messages are deleted based on SnapshotCountRetentionCriteria.snapshotEveryNEvents before old snapshots are deleted.