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

Removing startsWatching and stopsWatching from docs and removing cruft

Browse source
This commit is contained in:
Viktor Klang 2011-12-02 01:04:33 +01:00
parent fcc6169ede
commit 879ea7c2b4
3 changed files with 1 additions and 13 deletions
Download patch file Download diff file Expand all files Collapse all files

3
akka-docs/java/remote-actors.rst
View file

@ -178,10 +178,7 @@ The messages that it prevents are all that extends 'LifeCycleMessage':
* case object ReceiveTimeout * case object ReceiveTimeout
It also prevents the client from invoking any life-cycle and side-effecting methods, such as: It also prevents the client from invoking any life-cycle and side-effecting methods, such as:
* start
* stop * stop
* startsWatching
* stopsWatching
* etc. * etc.
Using secure cookie for remote client authentication Using secure cookie for remote client authentication

3
akka-docs/scala/remote-actors.rst
View file

@ -180,10 +180,7 @@ The messages that it prevents are all that extends 'LifeCycleMessage':
* class ReceiveTimeout..) * class ReceiveTimeout..)
It also prevents the client from invoking any life-cycle and side-effecting methods, such as: It also prevents the client from invoking any life-cycle and side-effecting methods, such as:
* start
* stop * stop
* startsWatching
* stopsWatching
* etc. * etc.
Using secure cookie for remote client authentication Using secure cookie for remote client authentication

8
akka-remote/src/main/scala/akka/remote/RemoteActorRefProvider.scala
View file

@ -296,7 +296,7 @@ private[akka] case class RemoteActorRef private[akka] (
def isTerminated: Boolean = !running def isTerminated: Boolean = !running
protected[akka] def sendSystemMessage(message: SystemMessage): Unit = unsupported protected[akka] def sendSystemMessage(message: SystemMessage): Unit = throw new UnsupportedOperationException("Not supported for RemoteActorRef")
override def !(message: Any)(implicit sender: ActorRef = null): Unit = remote.send(message, Option(sender), remoteAddress, this, loader) override def !(message: Any)(implicit sender: ActorRef = null): Unit = remote.send(message, Option(sender), remoteAddress, this, loader)
@ -318,11 +318,5 @@ private[akka] case class RemoteActorRef private[akka] (
@throws(classOf[java.io.ObjectStreamException]) @throws(classOf[java.io.ObjectStreamException])
private def writeReplace(): AnyRef = provider.serialize(this) private def writeReplace(): AnyRef = provider.serialize(this)
def startsWatching(actorRef: ActorRef): ActorRef = unsupported //FIXME Implement
def stopsWatching(actorRef: ActorRef): ActorRef = unsupported //FIXME Implement
protected[akka] def restart(cause: Throwable): Unit = () protected[akka] def restart(cause: Throwable): Unit = ()
private def unsupported = throw new UnsupportedOperationException("Not supported for RemoteActorRef")
} }