Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
Roiocam committed Apr 26, 2024
1 parent fb403b3 commit 10ff3c8
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 21 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -14,28 +14,21 @@

package org.apache.pekko.persistence.jdbc.query

import com.typesafe.config.{ ConfigValue, ConfigValueFactory }
import org.apache.pekko.actor.{ ActorRef, ExtendedActorSystem }
import org.apache.pekko.pattern.ask
import org.apache.pekko.persistence.jdbc.config.JournalConfig
import org.apache.pekko.persistence.jdbc.journal.dao.{ DefaultJournalDao, JournalDao }
import com.typesafe.config.{ConfigValue, ConfigValueFactory}
import org.apache.pekko.persistence.jdbc.query.JournalDaoStreamMessagesMemoryTest.fetchSize
import org.apache.pekko.persistence.{ AtomicWrite, PersistentRepr }
import org.apache.pekko.serialization.{ Serialization, SerializationExtension }
import org.apache.pekko.stream.scaladsl.{ Sink, Source }
import org.apache.pekko.persistence.{AtomicWrite, PersistentRepr}
import org.apache.pekko.stream.scaladsl.{Sink, Source}
import org.apache.pekko.stream.testkit.scaladsl.TestSink
import org.apache.pekko.stream.{ Materializer, SystemMaterializer }
import org.apache.pekko.stream.{Materializer, SystemMaterializer}
import org.scalatest.concurrent.PatienceConfiguration.Timeout
import org.slf4j.LoggerFactory
import slick.jdbc.JdbcBackend.Database
import slick.jdbc.JdbcProfile

import java.lang.management.{ ManagementFactory, MemoryMXBean }
import java.lang.management.{ManagementFactory, MemoryMXBean}
import java.util.UUID
import scala.collection.immutable
import scala.concurrent.ExecutionContext
import scala.concurrent.duration._
import scala.util.{ Failure, Success }
import scala.util.{Failure, Success}

object JournalDaoStreamMessagesMemoryTest {

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -9,14 +9,7 @@

package org.apache.pekko.persistence.jdbc.integration

import org.apache.pekko.persistence.jdbc.query.{
DefaultJournalDaoStreamMessagesMemoryTest,
JournalDaoStreamMessagesMemoryTest,
MysqlCleaner,
OracleCleaner,
PostgresCleaner,
SqlServerCleaner
}
import org.apache.pekko.persistence.jdbc.query.{JournalDaoStreamMessagesMemoryTest, MysqlCleaner, OracleCleaner, PostgresCleaner, SqlServerCleaner}

class PostgresJournalDaoStreamMessagesMemoryTest
extends JournalDaoStreamMessagesMemoryTest("postgres-application.conf")
Expand Down

0 comments on commit 10ff3c8

Please sign in to comment.