私は奇妙な例外に直面しています
java.lang.ClassCastException: Cannot cast akka.actor.Status$Success$ to akka.actor.Status$Success
at java.lang.Class.cast(Class.java:3094) ~[na:1.7.0_45]
at scala.concurrent.Future$$anonfun$mapTo$1.apply(Future.scala:405) ~[scala-library.jar:na]
at scala.util.Success$$anonfun$map$1.apply(Try.scala:206) ~[scala-library.jar:na]
at scala.util.Try$.apply(Try.scala:161) ~[scala-library.jar:na]
at scala.util.Success.map(Try.scala:206) ~[scala-library.jar:na]
問題は末尾の $ です - 内部クラスなどのようなもの..
私のコードは次のとおりです。
post {
authenticate(BasicAuth(pifUserPasswordAuthenticator _, realm = "bd pif import api")) {
user =>
entity(as[Array[Byte]]) { e =>
val resp = pifImportService.ask(PifTransactions("storeId","dob",e)).mapTo[akka.actor.Status.Success]
complete {
resp
}
}
}
}
私の俳優のために、次のように返信しています。
Try(kafkaProducer.send(payload)) match {
case Success(_) =>
log.debug(s"$storeId - $dob - sending payload sucessfully sended to kafka")
sender() ! akka.actor.Status.Success
case Failure(throwable) =>
log.debug(s"$storeId - $dob - sending payload attempt failed $throwable")
sender() ! akka.actor.Status.Failure(throwable)
}
何かトリックを見逃していますか、それともここで間違った名前を使用していますか?
どうも