try this

nylonee · Nov 14, 2023 · f856e1c · f856e1c
1 parent a4bd376
commit f856e1c
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 3 deletions.
diff --git a/src/main/scala/Server.scala b/src/main/scala/Server.scala
@@ -3,16 +3,19 @@ import cats.effect._
 import cats.effect.std.Semaphore
 import configuration.{Configuration, ConfigurationUtils, SystemPropertyReader}
 import org.http4s.ember.client.EmberClientBuilder
+import org.typelevel.log4cats.slf4j.Slf4jLogger
 import utils.HttpClient
 
 object Server extends IOApp {
+
+ private val logger = Slf4jLogger.getLogger[IO]
  def run(args: List[String]): IO[ExitCode] = {
- val maxConcurrentOutgoingRequests = 1
+ val maxConcurrentOutgoingRequests = 2
 
  for {
  semaphore <- Semaphore[IO](maxConcurrentOutgoingRequests)
  configReader = SystemPropertyReader
- clientResource = EmberClientBuilder.default[IO].build
+ clientResource = EmberClientBuilder.default[IO].withLogger(logger).build
  httpClient = new HttpClient(clientResource, semaphore)
  memoizedConfigIo <- ConfigurationUtils.create(configReader, httpClient).memoize
  result <- periodicTask(memoizedConfigIo, httpClient).foreverM.as(ExitCode.Success)

diff --git a/src/main/scala/utils/HttpClient.scala b/src/main/scala/utils/HttpClient.scala
@@ -23,4 +23,4 @@ class HttpClient(http4sClient: Resource[IO, Client[IO]], semaphore: Semaphore[IO
  http4sClient.use(_.expect[Json](requestWithPayload).attempt)
  }
  }
-}
+}