#2348 - SI-4804 is fixed so enabling serialversionuids
This commit is contained in:
parent
6c5826ab23
commit
ef6b78dbc5
8 changed files with 19 additions and 19 deletions
|
|
@ -11,7 +11,7 @@ package akka
|
||||||
* <li>toString that includes exception name, message and uuid</li>
|
* <li>toString that includes exception name, message and uuid</li>
|
||||||
* </ul>
|
* </ul>
|
||||||
*/
|
*/
|
||||||
//TODO add @SerialVersionUID(1L) when SI-4804 is fixed
|
@SerialVersionUID(1L)
|
||||||
class AkkaException(message: String, cause: Throwable) extends RuntimeException(message, cause) with Serializable {
|
class AkkaException(message: String, cause: Throwable) extends RuntimeException(message, cause) with Serializable {
|
||||||
def this(msg: String) = this(msg, null)
|
def this(msg: String) = this(msg, null)
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -32,7 +32,7 @@ object ActorPath {
|
||||||
* is sorted by path elements FROM RIGHT TO LEFT, where RootActorPath >
|
* is sorted by path elements FROM RIGHT TO LEFT, where RootActorPath >
|
||||||
* ChildActorPath in case the number of elements is different.
|
* ChildActorPath in case the number of elements is different.
|
||||||
*/
|
*/
|
||||||
//TODO add @SerialVersionUID(1L) when SI-4804 is fixed
|
@SerialVersionUID(1L)
|
||||||
sealed trait ActorPath extends Comparable[ActorPath] with Serializable {
|
sealed trait ActorPath extends Comparable[ActorPath] with Serializable {
|
||||||
/**
|
/**
|
||||||
* The Address under which this path can be reached; walks up the tree to
|
* The Address under which this path can be reached; walks up the tree to
|
||||||
|
|
@ -103,7 +103,7 @@ sealed trait ActorPath extends Comparable[ActorPath] with Serializable {
|
||||||
* Root of the hierarchy of ActorPaths. There is exactly root per ActorSystem
|
* Root of the hierarchy of ActorPaths. There is exactly root per ActorSystem
|
||||||
* and node (for remote-enabled or clustered systems).
|
* and node (for remote-enabled or clustered systems).
|
||||||
*/
|
*/
|
||||||
//TODO add @SerialVersionUID(1L) when SI-4804 is fixed
|
@SerialVersionUID(1L)
|
||||||
final case class RootActorPath(address: Address, name: String = "/") extends ActorPath {
|
final case class RootActorPath(address: Address, name: String = "/") extends ActorPath {
|
||||||
|
|
||||||
override def parent: ActorPath = this
|
override def parent: ActorPath = this
|
||||||
|
|
@ -126,7 +126,7 @@ final case class RootActorPath(address: Address, name: String = "/") extends Act
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
//TODO add @SerialVersionUID(1L) when SI-4804 is fixed
|
@SerialVersionUID(1L)
|
||||||
final class ChildActorPath(val parent: ActorPath, val name: String) extends ActorPath {
|
final class ChildActorPath(val parent: ActorPath, val name: String) extends ActorPath {
|
||||||
if (name.indexOf('/') != -1) throw new IllegalArgumentException("/ is a path separator and is not legal in ActorPath names: [%s]" format name)
|
if (name.indexOf('/') != -1) throw new IllegalArgumentException("/ is a path separator and is not legal in ActorPath names: [%s]" format name)
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -350,7 +350,7 @@ private[akka] class LocalActorRef private[akka] (
|
||||||
* Memento pattern for serializing ActorRefs transparently
|
* Memento pattern for serializing ActorRefs transparently
|
||||||
* INTERNAL API
|
* INTERNAL API
|
||||||
*/
|
*/
|
||||||
//TODO add @SerialVersionUID(1L) when SI-4804 is fixed
|
@SerialVersionUID(1L)
|
||||||
private[akka] case class SerializedActorRef private (path: String) {
|
private[akka] case class SerializedActorRef private (path: String) {
|
||||||
import akka.serialization.JavaSerializer.currentSystem
|
import akka.serialization.JavaSerializer.currentSystem
|
||||||
|
|
||||||
|
|
@ -408,7 +408,7 @@ private[akka] trait MinimalActorRef extends InternalActorRef with LocalRef {
|
||||||
case class DeadLetter(message: Any, sender: ActorRef, recipient: ActorRef)
|
case class DeadLetter(message: Any, sender: ActorRef, recipient: ActorRef)
|
||||||
|
|
||||||
private[akka] object DeadLetterActorRef {
|
private[akka] object DeadLetterActorRef {
|
||||||
//TODO add @SerialVersionUID(1L) when SI-4804 is fixed
|
@SerialVersionUID(1L)
|
||||||
class SerializedDeadLetterActorRef extends Serializable { //TODO implement as Protobuf for performance?
|
class SerializedDeadLetterActorRef extends Serializable { //TODO implement as Protobuf for performance?
|
||||||
@throws(classOf[java.io.ObjectStreamException])
|
@throws(classOf[java.io.ObjectStreamException])
|
||||||
private def readResolve(): AnyRef = JavaSerializer.currentSystem.value.deadLetters
|
private def readResolve(): AnyRef = JavaSerializer.currentSystem.value.deadLetters
|
||||||
|
|
|
||||||
|
|
@ -27,7 +27,7 @@ import annotation.tailrec
|
||||||
* context.actorOf(someProps, "someName", Deploy(scope = RemoteScope("someOtherNodeName")))
|
* context.actorOf(someProps, "someName", Deploy(scope = RemoteScope("someOtherNodeName")))
|
||||||
* }}}
|
* }}}
|
||||||
*/
|
*/
|
||||||
//TODO add @SerialVersionUID(1L) when SI-4804 is fixed
|
@SerialVersionUID(1L)
|
||||||
final case class Deploy(
|
final case class Deploy(
|
||||||
path: String = "",
|
path: String = "",
|
||||||
config: Config = ConfigFactory.empty,
|
config: Config = ConfigFactory.empty,
|
||||||
|
|
@ -76,7 +76,7 @@ trait Scope {
|
||||||
def withFallback(other: Scope): Scope
|
def withFallback(other: Scope): Scope
|
||||||
}
|
}
|
||||||
|
|
||||||
//TODO add @SerialVersionUID(1L) when SI-4804 is fixed
|
@SerialVersionUID(1L)
|
||||||
abstract class LocalScope extends Scope
|
abstract class LocalScope extends Scope
|
||||||
|
|
||||||
//FIXME docs
|
//FIXME docs
|
||||||
|
|
@ -92,7 +92,7 @@ case object LocalScope extends LocalScope {
|
||||||
/**
|
/**
|
||||||
* This is the default value and as such allows overrides.
|
* This is the default value and as such allows overrides.
|
||||||
*/
|
*/
|
||||||
//TODO add @SerialVersionUID(1L) when SI-4804 is fixed
|
@SerialVersionUID(1L)
|
||||||
abstract class NoScopeGiven extends Scope
|
abstract class NoScopeGiven extends Scope
|
||||||
case object NoScopeGiven extends NoScopeGiven {
|
case object NoScopeGiven extends NoScopeGiven {
|
||||||
def withFallback(other: Scope): Scope = other
|
def withFallback(other: Scope): Scope = other
|
||||||
|
|
|
||||||
|
|
@ -113,7 +113,7 @@ object Props {
|
||||||
* Props props = new Props(MyActor.class).withRouter(new RoundRobinRouter(..));
|
* Props props = new Props(MyActor.class).withRouter(new RoundRobinRouter(..));
|
||||||
* }}}
|
* }}}
|
||||||
*/
|
*/
|
||||||
//TODO add @SerialVersionUID(1L) when SI-4804 is fixed when SI-4804 is fixed
|
@SerialVersionUID(1L)
|
||||||
case class Props(
|
case class Props(
|
||||||
creator: () ⇒ Actor = Props.defaultCreator,
|
creator: () ⇒ Actor = Props.defaultCreator,
|
||||||
dispatcher: String = Dispatchers.DefaultDispatcherId,
|
dispatcher: String = Dispatchers.DefaultDispatcherId,
|
||||||
|
|
|
||||||
|
|
@ -494,7 +494,7 @@ object TypedProps {
|
||||||
* TypedProps is a TypedActor configuration object, that is thread safe and fully sharable.
|
* TypedProps is a TypedActor configuration object, that is thread safe and fully sharable.
|
||||||
* It's used in TypedActorFactory.typedActorOf to configure a TypedActor instance.
|
* It's used in TypedActorFactory.typedActorOf to configure a TypedActor instance.
|
||||||
*/
|
*/
|
||||||
//TODO add @SerialVersionUID(1L) when SI-4804 is fixed
|
@SerialVersionUID(1L)
|
||||||
case class TypedProps[T <: AnyRef] protected[TypedProps] (
|
case class TypedProps[T <: AnyRef] protected[TypedProps] (
|
||||||
interfaces: Seq[Class[_]],
|
interfaces: Seq[Class[_]],
|
||||||
creator: () ⇒ T,
|
creator: () ⇒ T,
|
||||||
|
|
|
||||||
|
|
@ -359,7 +359,7 @@ case class Destination(sender: ActorRef, recipient: ActorRef)
|
||||||
* from lower-precedence sources. The decision whether or not to create a
|
* from lower-precedence sources. The decision whether or not to create a
|
||||||
* router is taken in the LocalActorRefProvider based on Props.
|
* router is taken in the LocalActorRefProvider based on Props.
|
||||||
*/
|
*/
|
||||||
//TODO add @SerialVersionUID(1L) when SI-4804 is fixed
|
@SerialVersionUID(1L)
|
||||||
abstract class NoRouter extends RouterConfig
|
abstract class NoRouter extends RouterConfig
|
||||||
case object NoRouter extends NoRouter {
|
case object NoRouter extends NoRouter {
|
||||||
def createRoute(props: Props, routeeProvider: RouteeProvider): Route = null // FIXME, null, really??
|
def createRoute(props: Props, routeeProvider: RouteeProvider): Route = null // FIXME, null, really??
|
||||||
|
|
@ -391,7 +391,7 @@ case object FromConfig extends FromConfig {
|
||||||
* This can be used when the dispatcher to be used for the head Router needs to be configured
|
* This can be used when the dispatcher to be used for the head Router needs to be configured
|
||||||
* (defaults to default-dispatcher).
|
* (defaults to default-dispatcher).
|
||||||
*/
|
*/
|
||||||
//TODO add @SerialVersionUID(1L) when SI-4804 is fixed
|
@SerialVersionUID(1L)
|
||||||
class FromConfig(val routerDispatcher: String = Dispatchers.DefaultDispatcherId)
|
class FromConfig(val routerDispatcher: String = Dispatchers.DefaultDispatcherId)
|
||||||
extends RouterConfig
|
extends RouterConfig
|
||||||
with Serializable {
|
with Serializable {
|
||||||
|
|
@ -462,7 +462,7 @@ object RoundRobinRouter {
|
||||||
* @param routees string representation of the actor paths of the routees that will be looked up
|
* @param routees string representation of the actor paths of the routees that will be looked up
|
||||||
* using `actorFor` in [[akka.actor.ActorRefProvider]]
|
* using `actorFor` in [[akka.actor.ActorRefProvider]]
|
||||||
*/
|
*/
|
||||||
//TODO add @SerialVersionUID(1L) when SI-4804 is fixed
|
@SerialVersionUID(1L)
|
||||||
case class RoundRobinRouter(nrOfInstances: Int = 0, routees: Iterable[String] = Nil, override val resizer: Option[Resizer] = None,
|
case class RoundRobinRouter(nrOfInstances: Int = 0, routees: Iterable[String] = Nil, override val resizer: Option[Resizer] = None,
|
||||||
val routerDispatcher: String = Dispatchers.DefaultDispatcherId,
|
val routerDispatcher: String = Dispatchers.DefaultDispatcherId,
|
||||||
val supervisorStrategy: SupervisorStrategy = Router.defaultSupervisorStrategy)
|
val supervisorStrategy: SupervisorStrategy = Router.defaultSupervisorStrategy)
|
||||||
|
|
@ -581,7 +581,7 @@ object RandomRouter {
|
||||||
* @param routees string representation of the actor paths of the routees that will be looked up
|
* @param routees string representation of the actor paths of the routees that will be looked up
|
||||||
* using `actorFor` in [[akka.actor.ActorRefProvider]]
|
* using `actorFor` in [[akka.actor.ActorRefProvider]]
|
||||||
*/
|
*/
|
||||||
//TODO add @SerialVersionUID(1L) when SI-4804 is fixed
|
@SerialVersionUID(1L)
|
||||||
case class RandomRouter(nrOfInstances: Int = 0, routees: Iterable[String] = Nil, override val resizer: Option[Resizer] = None,
|
case class RandomRouter(nrOfInstances: Int = 0, routees: Iterable[String] = Nil, override val resizer: Option[Resizer] = None,
|
||||||
val routerDispatcher: String = Dispatchers.DefaultDispatcherId,
|
val routerDispatcher: String = Dispatchers.DefaultDispatcherId,
|
||||||
val supervisorStrategy: SupervisorStrategy = Router.defaultSupervisorStrategy)
|
val supervisorStrategy: SupervisorStrategy = Router.defaultSupervisorStrategy)
|
||||||
|
|
@ -707,7 +707,7 @@ object SmallestMailboxRouter {
|
||||||
* @param routees string representation of the actor paths of the routees that will be looked up
|
* @param routees string representation of the actor paths of the routees that will be looked up
|
||||||
* using `actorFor` in [[akka.actor.ActorRefProvider]]
|
* using `actorFor` in [[akka.actor.ActorRefProvider]]
|
||||||
*/
|
*/
|
||||||
//TODO add @SerialVersionUID(1L) when SI-4804 is fixed
|
@SerialVersionUID(1L)
|
||||||
case class SmallestMailboxRouter(nrOfInstances: Int = 0, routees: Iterable[String] = Nil, override val resizer: Option[Resizer] = None,
|
case class SmallestMailboxRouter(nrOfInstances: Int = 0, routees: Iterable[String] = Nil, override val resizer: Option[Resizer] = None,
|
||||||
val routerDispatcher: String = Dispatchers.DefaultDispatcherId,
|
val routerDispatcher: String = Dispatchers.DefaultDispatcherId,
|
||||||
val supervisorStrategy: SupervisorStrategy = Router.defaultSupervisorStrategy)
|
val supervisorStrategy: SupervisorStrategy = Router.defaultSupervisorStrategy)
|
||||||
|
|
@ -907,7 +907,7 @@ object BroadcastRouter {
|
||||||
* @param routees string representation of the actor paths of the routees that will be looked up
|
* @param routees string representation of the actor paths of the routees that will be looked up
|
||||||
* using `actorFor` in [[akka.actor.ActorRefProvider]]
|
* using `actorFor` in [[akka.actor.ActorRefProvider]]
|
||||||
*/
|
*/
|
||||||
//TODO add @SerialVersionUID(1L) when SI-4804 is fixed
|
@SerialVersionUID(1L)
|
||||||
case class BroadcastRouter(nrOfInstances: Int = 0, routees: Iterable[String] = Nil, override val resizer: Option[Resizer] = None,
|
case class BroadcastRouter(nrOfInstances: Int = 0, routees: Iterable[String] = Nil, override val resizer: Option[Resizer] = None,
|
||||||
val routerDispatcher: String = Dispatchers.DefaultDispatcherId,
|
val routerDispatcher: String = Dispatchers.DefaultDispatcherId,
|
||||||
val supervisorStrategy: SupervisorStrategy = Router.defaultSupervisorStrategy)
|
val supervisorStrategy: SupervisorStrategy = Router.defaultSupervisorStrategy)
|
||||||
|
|
@ -1018,7 +1018,7 @@ object ScatterGatherFirstCompletedRouter {
|
||||||
* @param routees string representation of the actor paths of the routees that will be looked up
|
* @param routees string representation of the actor paths of the routees that will be looked up
|
||||||
* using `actorFor` in [[akka.actor.ActorRefProvider]]
|
* using `actorFor` in [[akka.actor.ActorRefProvider]]
|
||||||
*/
|
*/
|
||||||
//TODO add @SerialVersionUID(1L) when SI-4804 is fixed
|
@SerialVersionUID(1L)
|
||||||
case class ScatterGatherFirstCompletedRouter(nrOfInstances: Int = 0, routees: Iterable[String] = Nil, within: Duration,
|
case class ScatterGatherFirstCompletedRouter(nrOfInstances: Int = 0, routees: Iterable[String] = Nil, within: Duration,
|
||||||
override val resizer: Option[Resizer] = None,
|
override val resizer: Option[Resizer] = None,
|
||||||
val routerDispatcher: String = Dispatchers.DefaultDispatcherId,
|
val routerDispatcher: String = Dispatchers.DefaultDispatcherId,
|
||||||
|
|
|
||||||
|
|
@ -10,7 +10,7 @@ import java.util.concurrent.TimeUnit
|
||||||
import java.lang.{ Double ⇒ JDouble }
|
import java.lang.{ Double ⇒ JDouble }
|
||||||
import scala.concurrent.util.Duration
|
import scala.concurrent.util.Duration
|
||||||
|
|
||||||
//TODO add @SerialVersionUID(1L) when SI-4804 is fixed
|
@SerialVersionUID(1L)
|
||||||
case class Timeout(duration: Duration) {
|
case class Timeout(duration: Duration) {
|
||||||
def this(timeout: Long) = this(Duration(timeout, TimeUnit.MILLISECONDS))
|
def this(timeout: Long) = this(Duration(timeout, TimeUnit.MILLISECONDS))
|
||||||
def this(length: Long, unit: TimeUnit) = this(Duration(length, unit))
|
def this(length: Long, unit: TimeUnit) = this(Duration(length, unit))
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue