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

Protobuf deep actor serialization working and test passing

Browse source
This commit is contained in:
Jonas Bonér 2010-06-22 07:22:47 +02:00
parent 5397e81ac5
commit 916cfe97c0
3 changed files with 1163 additions and 1164 deletions
Download patch file Download diff file Expand all files Collapse all files

2321
akka-core/src/main/java/se/scalablesolutions/akka/remote/protocol/RemoteProtocol.java
View file

File diff suppressed because it is too large Load diff

4
akka-core/src/main/protocol/RemoteProtocol.proto
View file

@ -32,8 +32,8 @@ message SerializedActorRefProtocol {
required string id = 2;
required string actorClassname = 3;
required bytes actorInstance = 4;
required string serializerClassname = 5;
required AddressProtocol originalAddress = 6;
required AddressProtocol originalAddress = 5;
optional string serializerClassname = 6;
optional bool isTransactor = 7;
optional uint64 timeout = 8;
optional LifeCycleProtocol lifeCycle = 9;

2
akka-core/src/test/scala/SerializableActorSpec.scala
View file

@ -29,7 +29,6 @@ class SerializableActorSpec extends
(actor2 !! "hello").getOrElse("_") should equal("world 2")
}
/*
it("should be able to serialize and deserialize a ProtobufSerializableActor") {
val actor1 = actorOf[ProtobufSerializableTestActor].start
(actor1 !! "hello").getOrElse("_") should equal("world 1")
@ -42,6 +41,7 @@ class SerializableActorSpec extends
(actor2 !! "hello").getOrElse("_") should equal("world 3")
}
/*
it("should be able to serialize and deserialize a JavaJSONSerializableActor") {
val actor1 = actorOf[JavaJSONSerializableTestActor].start
val serializer = actor1.serializer.getOrElse(fail("Serializer not defined"))