make more codec instances private

akka · Jan 31, 2024 · 6410fc8 · 6410fc8
1 parent 342c45d
commit 6410fc8
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 6 deletions.
diff --git a/core/src/main/scala/akka/persistence/r2dbc/internal/sqlserver/SqlServerQueryDao.scala b/core/src/main/scala/akka/persistence/r2dbc/internal/sqlserver/SqlServerQueryDao.scala
@@ -5,9 +5,6 @@
 package akka.persistence.r2dbc.internal.sqlserver
 
 import java.time.Instant
-import java.time.LocalDateTime
-import java.time.ZoneId
-import java.util.Date.UTC
 
 import scala.concurrent.ExecutionContext
 import scala.concurrent.Future
@@ -19,7 +16,6 @@ import akka.annotation.InternalApi
 import akka.persistence.r2dbc.R2dbcSettings
 import akka.persistence.r2dbc.internal.InstantFactory
 import akka.persistence.r2dbc.internal.Sql.Interpolation
-import akka.persistence.r2dbc.internal.codec.TimestampCodec.SqlServerTimestampCodec
 import akka.persistence.r2dbc.internal.codec.TimestampCodec.TimestampCodecRichStatement
 import akka.persistence.r2dbc.internal.postgres.PostgresQueryDao
 import io.r2dbc.spi.ConnectionFactory

diff --git a/core/src/test/scala/akka/persistence/r2dbc/journal/PersistTagsSpec.scala b/core/src/test/scala/akka/persistence/r2dbc/journal/PersistTagsSpec.scala
@@ -29,7 +29,7 @@ class PersistTagsSpec
 
   override def typedSystem: ActorSystem[_] = system
   private val settings = R2dbcSettings(system.settings.config.getConfig("akka.persistence.r2dbc"))
-  implicit val tagsCodec: TagsCodec = settings.tagsCodec
+  private implicit val tagsCodec: TagsCodec = settings.tagsCodec
   case class Row(pid: String, seqNr: Long, tags: Set[String])
 
   "Persist tags" should {

diff --git a/migration/src/main/scala/akka/persistence/r2dbc/migration/MigrationToolDao.scala b/migration/src/main/scala/akka/persistence/r2dbc/migration/MigrationToolDao.scala
@@ -36,7 +36,7 @@ import org.slf4j.LoggerFactory
     logDbCallsExceeding: FiniteDuration,
     closeCallsExceeding: Option[FiniteDuration])(implicit ec: ExecutionContext, system: ActorSystem[_]) {
   import MigrationToolDao._
-  implicit val queryAdapter: QueryAdapter = IdentityAdapter
+  private implicit val queryAdapter: QueryAdapter = IdentityAdapter
   private val r2dbcExecutor =
     new R2dbcExecutor(connectionFactory, log, logDbCallsExceeding, closeCallsExceeding)(ec, system)