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

pluggable serializers - changed entry name in akka.conf to serialization-bindings. Also updated akka-reference.conf with a commented section on pluggable serializers

Browse source
This commit is contained in:
Debasish Ghosh 2011-06-15 13:42:22 +05:30
parent 01c01e9771
commit a7dffdd445
3 changed files with 19 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-actor-tests/src/test/scala/akka/serialization/akka-serializer.conf
View file

@ -7,7 +7,7 @@ akka {
default = "akka.serialization.JavaSerializer"
}
bindings {
serialization-bindings {
java = ["akka.serialization.SerializeSpec$Address", "akka.serialization.MyJavaSerializableActor", "akka.serialization.MyStatelessActorWithMessagesInMailbox", "akka.serialization.MyActorWithProtobufMessagesInMailbox"]
sjson = ["akka.serialization.SerializeSpec$Person"]
proto = ["com.google.protobuf.Message", "akka.actor.ProtobufProtocol$MyMessage"]

2
akka-actor/src/main/scala/akka/config/Config.scala
View file

@ -122,7 +122,7 @@ object Config {
val serializers = config.getSection("akka.actor.serializers").map(_.map).getOrElse(Map("default" -> "akka.serialization.JavaSerializer"))
val bindings = config.getSection("akka.actor.bindings")
val bindings = config.getSection("akka.actor.serialization-bindings")
.map(_.map)
.map(m ⇒ Map() ++ m.map { case (k, v: List[String]) ⇒ Map() ++ v.map((_, k)) }.flatten)

17
config/akka-reference.conf
View file

@ -137,6 +137,23 @@ akka {
message-time-to-live = 120
}
}
# entries for pluggable serializers and their bindings
# if a binding for a specific class is not found, then the default
# serializer is used
#
# serializers {
# java = "akka.serialization.JavaSerializer"
# proto = "akka.testing.ProtobufSerializer"
# sjson = "akka.testing.SJSONSerializer"
# default = "akka.serialization.JavaSerializer"
# }
# serialization-bindings {
# java = ["akka.serialization.SerializeSpec$Address", "akka.serialization.MyJavaSerializableActor", "akka.serialization.MyStatelessActorWithMessagesInMailbox", "akka.serialization.MyActorWithProtobufMessagesInMailbox"]
# sjson = ["akka.serialization.SerializeSpec$Person"]
# proto = ["com.google.protobuf.Message", "akka.actor.ProtobufProtocol$MyMessage"]
# }
}
cluster {