diff --git a/core/src/main/scala/akka/persistence/r2dbc/internal/postgres/PostgresDurableStateDao.scala b/core/src/main/scala/akka/persistence/r2dbc/internal/postgres/PostgresDurableStateDao.scala index e133b2ff..de7c165b 100644 --- a/core/src/main/scala/akka/persistence/r2dbc/internal/postgres/PostgresDurableStateDao.scala +++ b/core/src/main/scala/akka/persistence/r2dbc/internal/postgres/PostgresDurableStateDao.scala @@ -100,8 +100,9 @@ private[r2dbc] class PostgresDurableStateDao( settings.connectionFactorySettings.poolSettings.closeCallsExceeding)(ec, system) private implicit val statePayloadCodec: PayloadCodec = settings.durableStatePayloadCodec - implicit val timestampCodec: TimestampCodec = settings.timestampCodec private implicit val tagsCodec: TagsCodec = settings.tagsCodec + + protected implicit val timestampCodec: TimestampCodec = settings.timestampCodec protected implicit val queryAdapter: QueryAdapter = settings.queryAdapter // used for change events