CODEWITHSUNDEEP
scalaakkaprotocol-buffers
CanardMoussant
CanardMoussant

Reputation: 923

Akka (JVM): Serialize an actorref with protobuf within another message

I have the following scala object that I would like to serialize with protobuf:

case class Worker(id: String, ref: ActorRef)

My understanding is that Akka comes with a ProtobufSerializer that I can use to serialize from/to ActorRef. Therefore I defined the following message in a proto file:

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

However the static methods ProtobufSerializer take an ExtentendActorSystem that I do not have at hand when I need to serialize those messages (only an ActorSystem through the context.system attribute of my actor). I am not sure how to actually serialize my object to protobuf and the other way around.

Upvotes: 0

Views: 745

Answers (1)

CanardMoussant
CanardMoussant

Reputation: 923

I am not sure in which cases it is true, but I was able to simply cast my ActorSystem to an ExtendedActorSystem. In my specific case (I am using Akka Persistence with Akka Singleton) it seems to work fine.

Upvotes: 0

Related Questions