From f856e1c194f35e074877383bc960b164172df95a Mon Sep 17 00:00:00 2001 From: Nihal Mirpuri Date: Tue, 14 Nov 2023 00:27:24 +0000 Subject: [PATCH] try this --- src/main/scala/Server.scala | 7 +++++-- src/main/scala/utils/HttpClient.scala | 2 +- 2 files changed, 6 insertions(+), 3 deletions(-) diff --git a/src/main/scala/Server.scala b/src/main/scala/Server.scala index 0742203..213645f 100644 --- 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 index b8e4f5e..e37c9f7 100644 --- 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) } } -} \ No newline at end of file +}