raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Merge pull request #17502 from spray/w/small-assorted-http-changes

Browse source 
Assorted http changes
This commit is contained in:
drewhk 2015-05-20 13:45:11 +02:00
commit 6149b328a0
2 changed files with 2 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

1
akka-http-core/src/main/resources/reference.conf
View file

@ -114,6 +114,7 @@ akka.http {
# The maximum number of times failed requests are attempted again,
# (if the request can be safely retried) before giving up and returning an error.
# Set to zero to completely disable request retries.
max-retries = 5
# The maximum number of open requests accepted into the pool across all

2
akka-http-core/src/main/scala/akka/http/impl/engine/client/PoolInterfaceActor.scala
View file

@ -106,7 +106,7 @@ private class PoolInterfaceActor(hcps: HostConnectionPoolSetup,
// if we can't dispatch right now we buffer and dispatch when demand from the pool arrives
if (inputBuffer.isFull) {
x.responsePromise.failure(
new RuntimeException(s"Exceeded configured max-open-requests value of [${inputBuffer.size}}]"))
new RuntimeException(s"Exceeded configured max-open-requests value of [${inputBuffer.size}]"))
} else inputBuffer.enqueue(x)
} else dispatchRequest(x) // if we can dispatch right now, do it
request(1) // for every incoming request we demand one response from the pool