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

Updating the Remote protocol to support control messages

Browse source
This commit is contained in:
Viktor Klang 2011-03-05 14:48:37 +01:00
parent 9e951435d5
commit fd6c879668
2 changed files with 1724 additions and 892 deletions
Download patch file Download diff file Expand all files Collapse all files

2596
akka-remote/src/main/java/akka/remote/protocol/RemoteProtocol.java
View file

File diff suppressed because it is too large Load diff

20
akka-remote/src/main/protocol/RemoteProtocol.proto
View file

@ -11,6 +11,11 @@ option optimize_for = SPEED;
protoc RemoteProtocol.proto --java_out ../java
*******************************************/
message AkkaRemoteProtocol {
optional RemoteMessageProtocol message = 1;
optional RemoteControlProtocol instruction = 2;
}
/**
* Defines a remote message.
*/
@ -26,6 +31,21 @@ message RemoteMessageProtocol {
optional string cookie = 9;
}
/**
* Defines some control messages for the remoting
*/
message RemoteControlProtocol {
optional string cookie = 1;
required CommandType commandType = 2;
}
/**
* Defines the type of the RemoteControlProtocol command type
*/
enum CommandType {
SHUTDOWN = 1;
}
/**
* Defines a remote ActorRef that "remembers" and uses its original Actor instance
* on the original node.