From b5beb30c5dc07c5e8fcbd6aab2f07f8700b1d397 Mon Sep 17 00:00:00 2001 From: Mathias Date: Mon, 11 May 2015 22:26:32 +0200 Subject: [PATCH] =htc Fix typo in error message and small improvement in reference.conf docs --- akka-http-core/src/main/resources/reference.conf | 1 + .../scala/akka/http/impl/engine/client/PoolInterfaceActor.scala | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/akka-http-core/src/main/resources/reference.conf b/akka-http-core/src/main/resources/reference.conf index 3e16de49eb..3c3b279edf 100644 --- a/akka-http-core/src/main/resources/reference.conf +++ b/akka-http-core/src/main/resources/reference.conf @@ -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 diff --git a/akka-http-core/src/main/scala/akka/http/impl/engine/client/PoolInterfaceActor.scala b/akka-http-core/src/main/scala/akka/http/impl/engine/client/PoolInterfaceActor.scala index 62aa113ffc..72238cb30b 100644 --- a/akka-http-core/src/main/scala/akka/http/impl/engine/client/PoolInterfaceActor.scala +++ b/akka-http-core/src/main/scala/akka/http/impl/engine/client/PoolInterfaceActor.scala @@ -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