Акка ошибка post.request.getReader - PullRequest
Новая
       9

Акка ошибка post.request.getReader

1 голос
/ 26 августа 2011

Я использую Акка-Мист и Протобуф.Язык Скала.Ошибка протобуфа

Тестовый отправитель: 

val (post, writer) = RestPostMock(ProtoBufPack.toByteString)
actor ? post

RestPostMock: 

object RestPostMock extends Mockito {
  def apply(msg: ByteString): (Post, StringWriter) = {
    val httpRequest = mock[HttpServletRequest]
    httpRequest.getReader returns new BufferedReader(new StringReader(msg.toStringUtf8))
    ...

Актеры: 

class CarStatusActor extends Actor {
  def receive = {
    case post: Post =>
      EventHandler.info(this, "received post test>>>>>>>>>>>>>>>>>>>")
      val readerInput = new ReaderInputStream(post.request.getReader)
      val protoBufPack = ProtoBufPack.parseFrom(readerInput)
      post.OK("Ok")
  }

В результате: 

INFO  [akka:event-driven:dispatcher:event:handler-1] akka.event.slf4j.Slf4jEventHandler - 
    [actorhandler.CarStatusActor]
    [received post test>>>>>>>>>>>>>>>>>>>]
ERROR [akka:event-driven:dispatcher:event:handler-1] akka.event.slf4j.Slf4jEventHandler - 
    [akka.testkit.TestActorRef]
    [Mock for Post, hashCode: 1039701893]
    [com.google.protobuf.InvalidProtocolBufferException: CodedInputStream encountered a malformed varint.
    at com.google.protobuf.InvalidProtocolBufferException.malformedVarint(InvalidProtocolBufferException.java:63)
...