Package akka.persistence.journal

Class JournalSpec

  • All Implemented Interfaces:
    CapabilityFlags, JournalCapabilityFlags, MayVerb, OptionalTests, TestKitBase, java.io.Serializable, org.scalactic.Explicitly, org.scalactic.Tolerance, org.scalactic.TripleEquals, org.scalactic.TripleEqualsSupport, org.scalatest.Alerting, org.scalatest.Assertions, org.scalatest.BeforeAndAfterAll, org.scalatest.BeforeAndAfterEach, org.scalatest.Documenting, org.scalatest.Informing, org.scalatest.Matchers, org.scalatest.Notifying, org.scalatest.Suite, org.scalatest.SuiteMixin, org.scalatest.TestRegistration, org.scalatest.TestSuite, org.scalatest.words.CanVerb, org.scalatest.words.MatcherWords, org.scalatest.words.MustVerb, org.scalatest.words.ShouldVerb, org.scalatest.WordSpecLike, scala.Serializable
    Direct Known Subclasses:
    JavaJournalSpec, JournalPerfSpec
    public abstract class JournalSpec
extends PluginSpec
implements MayVerb, OptionalTests, JournalCapabilityFlags
    Overridable hook that is called before populating the journal for the next test case. pid is the persistenceId that will be used in the test. This method may be needed to clean pre-existing events from the log.
    See Also:
    Serialized Form

    • Constructor Detail

      • JournalSpec

        public JournalSpec​(com.typesafe.config.Config config)

    • Method Detail

      • config

        public static com.typesafe.config.Config config()

      • beforeEach

        protected void beforeEach()
        Specified by:
        beforeEach in interface org.scalatest.BeforeAndAfterEach
        Overrides:
        beforeEach in class PluginSpec

      • preparePersistenceId

        public void preparePersistenceId​(java.lang.String pid)
        Overridable hook that is called before populating the journal for the next test case. pid is the persistenceId that will be used in the test. This method may be needed to clean pre-existing events from the log.
        Parameters:
        pid - (undocumented)

      • supportsAtomicPersistAllOfSeveralEvents

        public boolean supportsAtomicPersistAllOfSeveralEvents()
        Implementation may override and return false if it does not support atomic writes of several events, as emitted by persistAll.
        Returns:
        (undocumented)

      • replayedMessage

        public JournalProtocol.ReplayedMessage replayedMessage​(long snr,
                                                       boolean deleted,
                                                       scala.collection.immutable.Seq<java.lang.String> confirms)

      • replayedMessage$default$2

        public boolean replayedMessage$default$2()

      • replayedMessage$default$3

        public scala.collection.immutable.Seq<java.lang.String> replayedMessage$default$3()

      • writeMessages

        public void writeMessages​(int fromSnr,
                          int toSnr,
                          java.lang.String pid,
                          ActorRef sender,
                          java.lang.String writerUuid)