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

Deprecating Client-managed remote actors

Browse source
This commit is contained in:
Viktor Klang 2011-03-10 18:31:03 +01:00
parent 00dea71492
commit e588a2c90c
1 changed files with 6 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

6
akka-actor/src/main/scala/akka/remoteinterface/RemoteInterface.scala
View file

@ -148,6 +148,7 @@ abstract class RemoteSupport extends ListenerManagement with RemoteServerModule
* val actor = actorOf(classOf[MyActor],"www.akka.io", 2552).start * val actor = actorOf(classOf[MyActor],"www.akka.io", 2552).start
* </pre> * </pre>
*/ */
@deprecated("Will be removed after 1.1")
def actorOf(factory: => Actor, host: String, port: Int): ActorRef = def actorOf(factory: => Actor, host: String, port: Int): ActorRef =
Actor.remote.clientManagedActorOf(() => factory, host, port) Actor.remote.clientManagedActorOf(() => factory, host, port)
@ -166,6 +167,7 @@ abstract class RemoteSupport extends ListenerManagement with RemoteServerModule
* val actor = actorOf(classOf[MyActor],"www.akka.io",2552).start * val actor = actorOf(classOf[MyActor],"www.akka.io",2552).start
* </pre> * </pre>
*/ */
@deprecated("Will be removed after 1.1")
def actorOf(clazz: Class[_ <: Actor], host: String, port: Int): ActorRef = { def actorOf(clazz: Class[_ <: Actor], host: String, port: Int): ActorRef = {
import ReflectiveAccess.{ createInstance, noParams, noArgs } import ReflectiveAccess.{ createInstance, noParams, noArgs }
clientManagedActorOf(() => clientManagedActorOf(() =>
@ -193,6 +195,7 @@ abstract class RemoteSupport extends ListenerManagement with RemoteServerModule
* val actor = actorOf[MyActor]("www.akka.io",2552).start * val actor = actorOf[MyActor]("www.akka.io",2552).start
* </pre> * </pre>
*/ */
@deprecated("Will be removed after 1.1")
def actorOf[T <: Actor : Manifest](host: String, port: Int): ActorRef = { def actorOf[T <: Actor : Manifest](host: String, port: Int): ActorRef = {
import ReflectiveAccess.{ createInstance, noParams, noArgs } import ReflectiveAccess.{ createInstance, noParams, noArgs }
clientManagedActorOf(() => clientManagedActorOf(() =>
@ -423,6 +426,7 @@ trait RemoteClientModule extends RemoteModule { self: RemoteModule =>
def typedActorFor[T](intfClass: Class[T], serviceId: String, implClassName: String, timeout: Long, hostname: String, port: Int, loader: ClassLoader): T = def typedActorFor[T](intfClass: Class[T], serviceId: String, implClassName: String, timeout: Long, hostname: String, port: Int, loader: ClassLoader): T =
typedActorFor(intfClass, serviceId, implClassName, timeout, hostname, port, Some(loader)) typedActorFor(intfClass, serviceId, implClassName, timeout, hostname, port, Some(loader))
@deprecated("Will be removed after 1.1")
def clientManagedActorOf(factory: () => Actor, host: String, port: Int): ActorRef def clientManagedActorOf(factory: () => Actor, host: String, port: Int): ActorRef
@ -462,7 +466,9 @@ trait RemoteClientModule extends RemoteModule { self: RemoteModule =>
private[akka] def deregisterSupervisorForActor(actorRef: ActorRef): ActorRef private[akka] def deregisterSupervisorForActor(actorRef: ActorRef): ActorRef
@deprecated("Will be removed after 1.1")
private[akka] def registerClientManagedActor(hostname: String, port: Int, uuid: Uuid): Unit private[akka] def registerClientManagedActor(hostname: String, port: Int, uuid: Uuid): Unit
@deprecated("Will be removed after 1.1")
private[akka] def unregisterClientManagedActor(hostname: String, port: Int, uuid: Uuid): Unit private[akka] def unregisterClientManagedActor(hostname: String, port: Int, uuid: Uuid): Unit
} }