Я пишу простой код клиента спрей:Попадая «мертвые буквы встречаются» с помощью спрея клиента
// ActorSystem("main-actor-system") initialized earlier in code
implicit val system = actorSystem
implicit val execctx: scala.concurrent.ExecutionContext = system.dispatcher
implicit val timeout = Timeout(10.seconds)
val pipeline: Future[pipelining.WithTransformerConcatenation[HttpRequest, Future[String]]] =
for (Http.HostConnectorInfo(connector, _) <-
IO(Http) ? Http.HostConnectorSetup("myservicehost", port = 80)
) yield sendReceive(connector) ~> unmarshal[String]
Await.ready(pipeline, 10 seconds)
// this is quite brute forse, what is better way?
val pl = pipeline.value.get.get
val response: Future[String] = pl { Get("/status")}
private val result: String = Await.result(response, 10 seconds)
response.foreach(r => println("result" + result))
Каждый раз, когда я бегу этот код я получаю
[INFO] [02/17/2016 15:31:15.596] [main-actor-system-akka.actor.default-dispatcher-3] [akka://main-actor-system/system/IO-TCP/selectors/$a/0] Message [akka.io.Tcp$Close$] from Actor[akka://main-actor-system/user/IO-HTTP/group-0/0#-1771046370] to Actor[akka://main-actor-system/system/IO-TCP/selectors/$a/0#1352725834] was not delivered. [1] dead letters encountered. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
Что я должен сделать, чтобы исправить это?
Этот журнал появляется каждый раз, когда я отправляю запрос клиенту. Система preaty большой объем, и каждый запрос сервера в конечном итоге вызывает http-клиент (другой микросервис). Могу ли я случайно что-то в конфигурации/инициализации клиента использовать его максимально эффективно? – Julias