I think this has reported here https://github.com/akka/akka/issues/17732
and maybe also https://github.com/akka/akka/issues/16597
/Patrik
On Sun, Jun 14, 2015 at 3:51 AM, Konrad Cichocki <kcicho...@abbrevi8.com>
wrote:
> Hello guys I have problems with using akka-http in my application. I have
> a function that is downloading images from multiple sources which looks
> pretty much like this:
>
> override lazy val http: HttpExt = Http()
> def requestWithRedirects(request: HttpRequest, retries: Int = 10)(implicit
> akkaSystem: ActorSystem, materializer: FlowMaterializer):
> Future[HttpResponse] = {
> TimeoutFuture(timeout, msg = "Download timed out!") {
> http.singleRequest(request)
> }.flatMap {
> response => handleResponse(request, response, retries)
> }.recoverWith {
> case e: Exception if retries > 0 =>
> requestWithRedirects(request, retries = retries - 1)
> }
> }
>
>
> My TimeoutFuture is working like described here:
> http://stackoverflow.com/questions/29318411/handle-timeout-of-response-in-akka-http/29330010#29330010
>
> And the actual problem is an error I'm getting after some time app is
> working:
>
> Message: RuntimeException: Exceeded configured max-open-requests value of
> [128]
>
> akka.http.impl.engine.client.PoolInterfaceActor$$anonfun$receive$1.applyOrElse
> in PoolInterfaceActor.scala::109
> akka.actor.Actor$class.aroundReceive in Actor.scala::467
>
> akka.http.impl.engine.client.PoolInterfaceActor.akka$stream$actor$ActorSubscriber$$super$aroundReceive
> in PoolInterfaceActor.scala::46
> akka.stream.actor.ActorSubscriber$class.aroundReceive in
> ActorSubscriber.scala::208
>
> akka.http.impl.engine.client.PoolInterfaceActor.akka$stream$actor$ActorPublisher$$super$aroundReceive
> in PoolInterfaceActor.scala::46
> akka.stream.actor.ActorPublisher$class.aroundReceive in
> ActorPublisher.scala::317
> akka.http.impl.engine.client.PoolInterfaceActor.aroundReceive in
> PoolInterfaceActor.scala::46
> akka.actor.ActorCell.receiveMessage in ActorCell.scala::516
> akka.actor.ActorCell.invoke in ActorCell.scala::487
> akka.dispatch.Mailbox.processMailbox in Mailbox.scala::238
> akka.dispatch.Mailbox.run in Mailbox.scala::220
> akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec in
> AbstractDispatcher.scala::397
> scala.concurrent.forkjoin.ForkJoinTask.doExec in ForkJoinTask.java::260
> scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask in
> ForkJoinPool.java::1339
> scala.concurrent.forkjoin.ForkJoinPool.runWorker in
> ForkJoinPool.java::1979
> scala.concurrent.forkjoin.ForkJoinWorkerThread.run in
> ForkJoinWorkerThread.java::107
>
>
>
>
> I think my problem is caused by connections that hangs and never returns
> and those are slowly taking may pool resources and after a while are
> causing mentioned error. What is puzzling me the most is why settings
>
> akka.http.client.connecting-timeout = 1 s
> akka.http.client.idle-timeout = 1 s
> akka.http.host-connection-pool.idle-timeout = 1 s
>
>
> doesn't force
>
> http.singleRequest(request)
>
>
>
> to terminate.
>
>
> Any ideas how to fix/walk around this issue?
>
> --
> >>>>>>>>>> Read the docs: http://akka.io/docs/
> >>>>>>>>>> Check the FAQ:
> http://doc.akka.io/docs/akka/current/additional/faq.html
> >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user
> ---
> You received this message because you are subscribed to the Google Groups
> "Akka User List" group.
> To unsubscribe from this group and stop receiving emails from it, send an
> email to akka-user+unsubscr...@googlegroups.com.
> To post to this group, send email to akka-user@googlegroups.com.
> Visit this group at http://groups.google.com/group/akka-user.
> For more options, visit https://groups.google.com/d/optout.
>
--
Patrik Nordwall
Typesafe <http://typesafe.com/> - Reactive apps on the JVM
Twitter: @patriknw
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ:
>>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user
---
You received this message because you are subscribed to the Google Groups "Akka
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
