Open akka-ci opened 8 years ago
Comment by marekzebrowski Tuesday Mar 15, 2016 at 07:39 GMT
... but singleRequest is buggy, or at least not obvious to use it right - it overflows connection pool immediately with:
Response exception: akka.stream.BaseOverflowStrategy$Fail$BufferOverflowException: Exceeded configured max-open-requests value of [32]
as reported in
https://groups.google.com/forum/?fromgroups#!searchin/akka-user/singleRequest/akka-user/t2pGKXclxMo/lB0swlYzDgAJ
Http().cachedHostConnectionPool
is working default for now.
Comment by danischroeter Thursday Jun 23, 2016 at 13:17 GMT
I did not find a bug about BufferOverflowException for Http().singleRequest but i just happened to run into the same problem. Is there a bug open? I just wonder how using Http().cachedHostConnectionPool can actually prevent having too many requests open if used by several independent actors?
Comment by 2beaucoup Thursday Jun 23, 2016 at 13:32 GMT
cachedHostConnectionPool
provides a flow which can apply backpressure to the upstream request source while singleRequest
fills its internal buffer up to max-open-requests
and then gives up. A workaround would be to await a response before the next request is send but that wouldn't properly utilize the pool.
Issue by ktoso Monday Mar 14, 2016 at 22:20 GMT Originally opened as https://github.com/akka/akka/issues/20030
As it's the simplest and most likely the API most people should be using. Currently docs come in order from "lowest level to" "request level", which noone understands that that is the "simple one".