2016-11-23 3 views
0

У меня есть следующий объект Scala, который я хотел бы сериализации с Protobuf:Акка (JVM): сериализовать actorref с Protobuf в другом сообщении

Я понимаю, что Акка приходит с ProtobufSerializer, что я могу использовать для сериализации от/до ActorRef. Поэтому я определил следующее сообщение в файле прото:

message Worker { 
    string id = 1; 
    bytes ref = 2; 
} 

Однако статические методы ProtobufSerializer принимают ExtentendActorSystem, что у меня нет под рукой, когда мне нужно сериализовать эти сообщения (лишь ActorSystem через атрибут context.system моего актера). Я не уверен, как фактически сериализовать мой объект на protobuf и наоборот.

ответ

0

Я не уверен, в каких случаях это правда, но я смог просто передать свою ActorSystem в ExtendedActorSystem. В моем конкретном случае (я использую Akka Persistence с Akka Singleton), похоже, что он работает нормально.