Interface JournalInteractions<C,​E,​S>

    • Method Detail

      • 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.