raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Binary compat work for Akka Remote

Browse source
This commit is contained in:
Viktor Klang 2012-05-24 11:44:39 +02:00
parent 568c02d158
commit 6bed19c6c9
10 changed files with 219 additions and 177 deletions
Download patch file Download diff file Expand all files Collapse all files

11
akka-remote/src/main/scala/akka/remote/MessageSerializer.scala
View file

@ -9,8 +9,14 @@ import com.google.protobuf.ByteString
import akka.actor.ExtendedActorSystem
import akka.serialization.SerializationExtension
object MessageSerializer {
/**
* MessageSerializer is a helper for serialize and deserialize messages
*/
private[akka] object MessageSerializer {
/**
* Uses Akka Serialization for the specified ActorSystem to transform the given MessageProtocol to a message
*/
def deserialize(system: ExtendedActorSystem, messageProtocol: MessageProtocol): AnyRef = {
val clazz =
if (messageProtocol.hasMessageManifest) {
@ -24,6 +30,9 @@ object MessageSerializer {
}
}
/**
* Uses Akka Serialization for the specified ActorSystem to transform the given message to a MessageProtocol
*/
def serialize(system: ExtendedActorSystem, message: AnyRef): MessageProtocol = {
val s = SerializationExtension(system)
val serializer = s.findSerializerFor(message)