为什么所有 HttpResponse 都被发送到死信（到目前为止它工作正常）？

Question

今天早上我的代码刚刚停止工作。所有 HttpResponse 现在都被 错误地 发送到 deadLetter。可能是什么问题？

class MyActor extends Actor {

  val mediator = DistributedPubSubExtension(context.system).mediator

  def receive = {
    case "tick" => {
      val pipeline = sendReceive ~> unmarshal[MyItems[Id]]
      val pipeline2: HttpRequest => Future[HttpResponse] = sendReceive

      val responseFuture: Future[MyItems[Id]] = pipeline(Get(path))
      responseFuture onComplete {
        case Success(json_items: MyItems[Id]) =>
          mediator.tell(DistributedPubSubMediator.Publish("I have response", ResponseTime(format.format(Calendar.getInstance().getTime())), self)  
        case Failure(t) => println("An error has occured: " + t.getMessage)
      }
    }
  }
}

Answer 1

问题是服务器发送了不同的消息，它们无法解析为 MyItems 对象，因此导致错误，服务器响应被转发到死信。

为什么所有 HttpResponse 都被发送到死信（到目前为止它工作正常）？

Why are all HttpResponse's sent to dead letters (it worked fine so far)?

scala

akka

spray