Могу ли я установить тайм-аут и количество повторных попыток для определенного запроса конвейера?

С файлом конфигурации

Я использую Spray 1.2.0 в системе Akka. Внутри моего актера я импортирую существующую систему Akka, поэтому я могу использовать файл конфигурации Akka по умолчанию.

implicit val system = context.system
import context.dispatcher
val pipeline: HttpRequest => Future[HttpResponse] = sendReceive

Теперь вы можете изменить конфигурацию в application.conf.

spray.can.host-connector {
    max-connections = 10
    max-retries = 3
    max-redirects = 0
    pipelining = off
    idle-timeout = 30 s
    client = ${spray.can.client}
}

В коде

Можно изменить настройки в коде с помощью HostConnectorSetup, но вы должны определить все параметры. (На основе примера использования спрея.)

val pipeline: Future[SendReceive] =
for (
  Http.HostConnectorInfo(connector, _) <-
  IO(Http) ? Http.HostConnectorSetup("www.spray.io", port = 80, settings = Some(new HostConnectorSettings(maxConnections = 3, maxRetries = 3, maxRedirects = 0, pipelining = false, idleTimeout = 5 seconds, connectionSettings = ClientConnectionSettings(...))))
) yield sendReceive(connector)

Я считаю, что самый простой способ переопределить тайм-аут по умолчанию в коде — это использовать неявный аргумент futureTimeout для метода sendReceive. Тип данных этого параметра — akka.util.Timeout. Итак, если вам нужен тайм-аут 120 секунд вместо 60 секунд по умолчанию, вы можете сделать это...

implicit val timeout = Timeout(120 seconds)
val urlpipeline = sendReceive ~> unmarshal[String]
urlpipeline { Get(url) }

Однако я не вижу никакого параметра, который позволил бы вашему клиентскому коду изменить максимальное количество повторных попыток аналогичным образом.