Path Lines of Code core/src/test/java/org/apache/pekko/persistence/jdbc/JavadslSnippets.java 59 core/src/test/java/org/apache/pekko/persistence/jdbc/state/JavadslSnippets.java 107 core/src/test/resources/logback-test.xml 16 core/src/test/scala-2/org/apache/pekko/persistence/jdbc/CrossEventually.scala 9 core/src/test/scala-3/org/apache/pekko/persistence/jdbc/CrossEventually.scala 8 core/src/test/scala/org/apache/pekko/persistence/jdbc/ScaladslSnippets.scala 50 core/src/test/scala/org/apache/pekko/persistence/jdbc/SharedActorSystemTestSpec.scala 32 core/src/test/scala/org/apache/pekko/persistence/jdbc/SimpleSpec.scala 29 core/src/test/scala/org/apache/pekko/persistence/jdbc/SingleActorSystemPerTestSpec.scala 67 core/src/test/scala/org/apache/pekko/persistence/jdbc/TablesTestSpec.scala 221 core/src/test/scala/org/apache/pekko/persistence/jdbc/configuration/ConfigOpsTest.scala 23 core/src/test/scala/org/apache/pekko/persistence/jdbc/configuration/JNDIConfigTest.scala 35 core/src/test/scala/org/apache/pekko/persistence/jdbc/configuration/PekkoPersistenceConfigTest.scala 299 core/src/test/scala/org/apache/pekko/persistence/jdbc/journal/JdbcJournalPerfSpec.scala 85 core/src/test/scala/org/apache/pekko/persistence/jdbc/journal/JdbcJournalSpec.scala 72 core/src/test/scala/org/apache/pekko/persistence/jdbc/journal/dao/LimitWindowingStreamTest.scala 61 core/src/test/scala/org/apache/pekko/persistence/jdbc/journal/dao/TrySeqTest.scala 34 core/src/test/scala/org/apache/pekko/persistence/jdbc/journal/dao/legacy/ByteArrayJournalSerializerTest.scala 27 core/src/test/scala/org/apache/pekko/persistence/jdbc/journal/dao/legacy/JournalTablesTest.scala 25 core/src/test/scala/org/apache/pekko/persistence/jdbc/journal/dao/legacy/TagsSerializationTest.scala 32 core/src/test/scala/org/apache/pekko/persistence/jdbc/query/AllPersistenceIdsTest.scala 40 core/src/test/scala/org/apache/pekko/persistence/jdbc/query/CurrentEventsByPersistenceIdTest.scala 203 core/src/test/scala/org/apache/pekko/persistence/jdbc/query/CurrentEventsByTagTest.scala 164 core/src/test/scala/org/apache/pekko/persistence/jdbc/query/CurrentLastSequenceNumberByPersistenceIdTest.scala 31 core/src/test/scala/org/apache/pekko/persistence/jdbc/query/CurrentPersistenceIdsTest.scala 26 core/src/test/scala/org/apache/pekko/persistence/jdbc/query/EventAdapterTest.scala 149 core/src/test/scala/org/apache/pekko/persistence/jdbc/query/EventsByPersistenceIdTest.scala 277 core/src/test/scala/org/apache/pekko/persistence/jdbc/query/EventsByTagTest.scala 350 core/src/test/scala/org/apache/pekko/persistence/jdbc/query/HardDeleteQueryTest.scala 70 core/src/test/scala/org/apache/pekko/persistence/jdbc/query/JournalDaoStreamMessagesMemoryTest.scala 92 core/src/test/scala/org/apache/pekko/persistence/jdbc/query/JournalSequenceActorTest.scala 229 core/src/test/scala/org/apache/pekko/persistence/jdbc/query/MultipleReadJournalTest.scala 18 core/src/test/scala/org/apache/pekko/persistence/jdbc/query/QueryTestSpec.scala 375 core/src/test/scala/org/apache/pekko/persistence/jdbc/query/TaggingEventAdapter.scala 16 core/src/test/scala/org/apache/pekko/persistence/jdbc/query/dao/ReadJournalTablesTest.scala 25 core/src/test/scala/org/apache/pekko/persistence/jdbc/query/dao/TestProbeReadJournalDao.scala 42 core/src/test/scala/org/apache/pekko/persistence/jdbc/serialization/StoreOnlySerializableMessagesTest.scala 101 core/src/test/scala/org/apache/pekko/persistence/jdbc/snapshot/JdbcSnapshotStoreSpec.scala 68 core/src/test/scala/org/apache/pekko/persistence/jdbc/snapshot/dao/legacy/SnapshotTablesTest.scala 27 core/src/test/scala/org/apache/pekko/persistence/jdbc/state/Payloads.scala 17 core/src/test/scala/org/apache/pekko/persistence/jdbc/state/ScaladslSnippets.scala 96 core/src/test/scala/org/apache/pekko/persistence/jdbc/state/scaladsl/DataGenerationHelper.scala 60 core/src/test/scala/org/apache/pekko/persistence/jdbc/state/scaladsl/DurableStateSequenceActorTest.scala 304 core/src/test/scala/org/apache/pekko/persistence/jdbc/state/scaladsl/DurableStateStorePluginSpec.scala 108 core/src/test/scala/org/apache/pekko/persistence/jdbc/state/scaladsl/JdbcDurableStateSpec.scala 342 core/src/test/scala/org/apache/pekko/persistence/jdbc/state/scaladsl/StateSpecBase.scala 105 core/src/test/scala/org/apache/pekko/persistence/jdbc/state/scaladsl/TestProbeDurableStateStoreQuery.scala 38 core/src/test/scala/org/apache/pekko/persistence/jdbc/util/ClasspathResources.scala 12 core/src/test/scala/org/apache/pekko/persistence/jdbc/util/DropCreate.scala 34 integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/AllPersistenceIdsTest.scala 14 integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/CurrentEventsByPersistenceIdTest.scala 20 integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/CurrentEventsByTagTest.scala 20 integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/CurrentLastKnownSequenceNumberByPersistenceIdTest.scala 20 integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/CurrentPersistenceIdsTest.scala 20 integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/DurableStateSequenceActorTest.scala 20 integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/DurableStateStorePluginSpec.scala 8 integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/EventAdapterTest.scala 12 integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/EventsByPersistenceIdTest.scala 18 integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/EventsByTagTest.scala 14 integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/HardDeleteQueryTest.scala 12 integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/JdbcJournalPerfSpec.scala 37 integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/JdbcJournalSpec.scala 29 integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/JdbcSnapshotStoreSpec.scala 26 integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/JournalDaoStreamMessagesMemoryTest.scala 20 integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/JournalSequenceActorTest.scala 20 integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/LimitWindowingStreamTest.scala 15 integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/PostgresDurableStateStorePluginSpec.scala 12 integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/PostgresScalaJdbcDurableStateChangesByTagTest.scala 11 integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/ScalaJdbcDurableStateStoreQueryTest.scala 26 integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/StoreOnlySerializableMessagesTest.scala 14 migrator-integration-test/src/test/resources/schema/h2/h2-create-schema-legacy.sql 30 migrator-integration-test/src/test/resources/schema/h2/h2-drop-schema-legacy.sql 3 migrator-integration-test/src/test/resources/schema/mysql/mysql-create-schema-legacy.sql 17 migrator-integration-test/src/test/resources/schema/mysql/mysql-drop-schema-legacy.sql 2 migrator-integration-test/src/test/resources/schema/oracle/oracle-create-schema-legacy.sql 37 migrator-integration-test/src/test/resources/schema/oracle/oracle-drop-schema-legacy.sql 12 migrator-integration-test/src/test/resources/schema/postgres/postgres-create-schema-legacy.sql 30 migrator-integration-test/src/test/resources/schema/postgres/postgres-drop-schema-legacy.sql 3 migrator-integration-test/src/test/resources/schema/sqlserver/sqlserver-create-schema-legacy.sql 17 migrator-integration-test/src/test/resources/schema/sqlserver/sqlserver-drop-schema-legacy.sql 2 migrator-integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/migrator/JournalMigratorTest.scala 120 migrator-integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/migrator/MigratorSpec.scala 311 migrator-integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/migrator/SnapshotMigratorTest.scala 47 migrator-integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/migrator/integration/JournalMigratorTest.scala 8 migrator-integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/migrator/integration/SnapshotMigratorTest.scala 8