diff --git a/modules/queue-processor/src/main/scala/PgCredentials.scala b/modules/queue-processor/src/main/scala/PgCredentials.scala index 7bb59f8..9d27ade 100644 --- a/modules/queue-processor/src/main/scala/PgCredentials.scala +++ b/modules/queue-processor/src/main/scala/PgCredentials.scala @@ -7,7 +7,9 @@ case class PgCredentials( database: String, password: Option[String], ssl: Boolean -) +): + override def toString(): String = + s"PgCredentials[host=$host:$port,user=$user,database=$database]" object PgCredentials: def defaults(mp: Map[String, String]) = diff --git a/modules/queue-processor/src/main/scala/Store.scala b/modules/queue-processor/src/main/scala/Store.scala index 33ec88e..0cf5055 100644 --- a/modules/queue-processor/src/main/scala/Store.scala +++ b/modules/queue-processor/src/main/scala/Store.scala @@ -342,7 +342,9 @@ object Store: given Tracer[IO] = Tracer.Implicits.noop[IO] - creds.toResource + creds + .flatTap(cr => Log.info(s"Credentials: $cr")) + .toResource .evalTap(migrate(_)) .flatMap( open(_, SkunkConfig)