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

=rem #21202 a first set of protobuf serializations for artery messages (#21380)

Browse source
This commit is contained in:
Johannes Rudolph 2016-09-08 17:58:25 +02:00 • committed by Patrik Nordwall
parent b127f1fdcf
commit 529b10a9f8
12 changed files with 6531 additions and 20 deletions
Download patch file Download diff file Expand all files Collapse all files

11
akka-remote/src/main/scala/akka/remote/artery/Control.scala
View file

@ -19,6 +19,9 @@ import akka.stream.stage.OutHandler
import akka.remote.UniqueAddress
import akka.util.OptionVal
/** INTERNAL API: marker trait for protobuf-serializable artery messages */
private[akka] trait ArteryMessage extends Serializable
/**
* INTERNAL API: Marker trait for reply messages
*/
@ -29,22 +32,22 @@ private[akka] trait Reply extends ControlMessage
* Marker trait for control messages that can be sent via the system message sub-channel
* but don't need full reliable delivery. E.g. `HandshakeReq` and `Reply`.
*/
private[akka] trait ControlMessage
private[akka] trait ControlMessage extends ArteryMessage
/**
* INTERNAL API
*/
private[akka] final case class Quarantined(from: UniqueAddress, to: UniqueAddress) extends ControlMessage // FIXME serialization
private[akka] final case class Quarantined(from: UniqueAddress, to: UniqueAddress) extends ControlMessage
/**
* INTERNAL API
*/
private[akka] case class ActorSystemTerminating(from: UniqueAddress) extends ControlMessage // FIXME serialization
private[akka] case class ActorSystemTerminating(from: UniqueAddress) extends ControlMessage
/**
* INTERNAL API
*/
private[akka] case class ActorSystemTerminatingAck(from: UniqueAddress) // FIXME serialization
private[akka] case class ActorSystemTerminatingAck(from: UniqueAddress) extends ArteryMessage
/**
* INTERNAL API