akka.remote.netty

NettyRemoteSupport

class NettyRemoteSupport extends RemoteSupport with NettyRemoteServerModule with NettyRemoteClientModule

Provides the implementation of the Netty remote support

Linear Supertypes
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Hide All
  2. Show all
  1. NettyRemoteSupport
  2. NettyRemoteClientModule
  3. NettyRemoteServerModule
  4. RemoteSupport
  5. RemoteClientModule
  6. RemoteServerModule
  7. RemoteModule
  8. ListenerManagement
  9. AnyRef
  10. Any
Visibility
  1. Public
  2. All

Instance Constructors

  1. new NettyRemoteSupport ()

Value Members

  1. def != (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  2. def != (arg0: Any): Boolean

    Attributes
    final
    Definition Classes
    Any
  3. def ## (): Int

    Attributes
    final
    Definition Classes
    AnyRef → Any
  4. def == (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  5. def == (arg0: Any): Boolean

    Attributes
    final
    Definition Classes
    Any
  6. val UUID_PREFIX : String

    Definition Classes
    RemoteModule
  7. def actorFor (serviceId: String, className: String, timeout: Long, host: String, port: Int, loader: Option[ClassLoader]): ActorRef

    Attributes
    protected[akka]
    Definition Classes
    NettyRemoteSupportRemoteClientModule
  8. def actorFor (serviceId: String, className: String, timeout: Long, hostname: String, port: Int): ActorRef

    Definition Classes
    RemoteClientModule
  9. def actorFor (classNameOrServiceId: String, timeout: Long, hostname: String, port: Int, loader: ClassLoader): ActorRef

    Definition Classes
    RemoteClientModule
  10. def actorFor (classNameOrServiceId: String, timeout: Long, hostname: String, port: Int): ActorRef

    Definition Classes
    RemoteClientModule
  11. def actorFor (serviceId: String, className: String, hostname: String, port: Int, loader: ClassLoader): ActorRef

    Definition Classes
    RemoteClientModule
  12. def actorFor (serviceId: String, className: String, hostname: String, port: Int): ActorRef

    Definition Classes
    RemoteClientModule
  13. def actorFor (classNameOrServiceId: String, hostname: String, port: Int, loader: ClassLoader): ActorRef

    Definition Classes
    RemoteClientModule
  14. def actorFor (classNameOrServiceId: String, hostname: String, port: Int): ActorRef

    Definition Classes
    RemoteClientModule
  15. def addListener (listener: ActorRef): Unit

    Adds the listener this this registry's listener list.

    Adds the listener this this registry's listener list. The listener is started by this method if manageLifeCycleOfListeners yields true.

    Definition Classes
    ListenerManagement
  16. def address : InetSocketAddress

    Gets the address of the server instance

    Gets the address of the server instance

    Definition Classes
    NettyRemoteServerModuleRemoteServerModule
  17. def asInstanceOf [T0] : T0

    Attributes
    final
    Definition Classes
    Any
  18. def clear : Unit

    Definition Classes
    RemoteSupport
  19. def clientManagedActorOf (factory: () ⇒ Actor, host: String, port: Int): ActorRef

    Definition Classes
    NettyRemoteSupportRemoteClientModule
  20. def clone (): AnyRef

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  21. def createActorFromClass (clazz: Class[_]): Actor

    Attributes
    protected
    Definition Classes
    RemoteSupport
  22. def eq (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  23. def equals (arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  24. lazy val eventHandler : ActorRef

    Definition Classes
    RemoteSupport
  25. def finalize (): Unit

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  26. def foreachListener (f: (ActorRef) ⇒ Unit): Unit

    Execute f with each listener as argument.

    Execute f with each listener as argument. ActorInitializationException is not handled.

    Attributes
    protected[akka]
    Definition Classes
    ListenerManagement
  27. def getClass (): java.lang.Class[_]

    Attributes
    final
    Definition Classes
    AnyRef
  28. val guard : ReentrantGuard

    Attributes
    protected
    Definition Classes
    RemoteServerModule
  29. def hasListener (listener: ActorRef): Boolean

    Checks if a specific listener is registered.

    Checks if a specific listener is registered. ActorInitializationException leads to removal of listener if that one isShutdown.

    Definition Classes
    ListenerManagement
  30. def hasListeners : Boolean

    Definition Classes
    ListenerManagement
  31. def hashCode (): Int

    Definition Classes
    AnyRef → Any
  32. def isInstanceOf [T0] : Boolean

    Attributes
    final
    Definition Classes
    Any
  33. def isRunning : Boolean

    Signals whether the server is up and running or not

    Signals whether the server is up and running or not

    Definition Classes
    NettyRemoteServerModuleRemoteServerModule
  34. def manageLifeCycleOfListeners : Boolean

    Specifies whether listeners should be started when added and stopped when removed or not

    Specifies whether listeners should be started when added and stopped when removed or not

    Attributes
    protected
    Definition Classes
    RemoteSupportListenerManagement
  35. def name : String

    Gets the name of the server instance

    Gets the name of the server instance

    Definition Classes
    NettyRemoteServerModuleRemoteServerModule
  36. def ne (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  37. def notify (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
  38. def notifyAll (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
  39. def notifyListeners (message: ⇒ Any): Unit

    Attributes
    protected[akka]
    Definition Classes
    RemoteSupportRemoteModuleListenerManagement
  40. val optimizeLocal : AtomicBoolean

  41. def optimizeLocalScoped_? (): Boolean

    Definition Classes
    NettyRemoteSupportRemoteModule
  42. def register (id: String, actorRef: ActorRef): Unit

    Register Remote Actor by a specific 'id' passed as argument.

    Register Remote Actor by a specific 'id' passed as argument.

    NOTE: If you use this method to register your remote actor then you must unregister the actor by this ID yourself.

    Definition Classes
    NettyRemoteServerModuleRemoteServerModule
  43. def register (actorRef: ActorRef): Unit

    Register Remote Actor by the Actor's 'id' field.

    Register Remote Actor by the Actor's 'id' field. It starts the Actor if it is not started already.

    Definition Classes
    RemoteServerModule
  44. def registerByUuid (actorRef: ActorRef): Unit

    Register Remote Actor by the Actor's uuid field.

    Register Remote Actor by the Actor's uuid field. It starts the Actor if it is not started already.

    Definition Classes
    NettyRemoteServerModuleRemoteServerModule
  45. def registerClientManagedActor (hostname: String, port: Int, uuid: Uuid): Unit

  46. def registerPerSession (id: String, factory: ⇒ ActorRef): Unit

    Register Remote Session Actor by a specific 'id' passed as argument.

    Register Remote Session Actor by a specific 'id' passed as argument.

    NOTE: If you use this method to register your remote actor then you must unregister the actor by this ID yourself.

    Definition Classes
    NettyRemoteServerModuleRemoteServerModule
  47. def registerPerSession (id: String, factory: Creator[ActorRef]): Unit

    Register Remote Session Actor by a specific 'id' passed as argument.

    Register Remote Session Actor by a specific 'id' passed as argument.

    NOTE: If you use this method to register your remote actor then you must unregister the actor by this ID yourself. Java API

    Definition Classes
    RemoteServerModule
  48. def registerTypedActor (id: String, typedActor: AnyRef): Unit

    Register remote typed actor by a specific id.

    Register remote typed actor by a specific id.

    id

    custom actor id

    typedActor

    typed actor to register

    Definition Classes
    NettyRemoteServerModuleRemoteServerModule
  49. def registerTypedActor (intfClass: Class[_], typedActor: AnyRef): Unit

    Register typed actor by interface name.

    Register typed actor by interface name.

    Definition Classes
    RemoteServerModule
  50. def registerTypedPerSessionActor (id: String, factory: ⇒ AnyRef): Unit

    Register remote typed actor by a specific id.

    Register remote typed actor by a specific id.

    id

    custom actor id

    Definition Classes
    NettyRemoteServerModuleRemoteServerModule
  51. def registerTypedPerSessionActor (id: String, factory: Creator[AnyRef]): Unit

    Register remote typed actor by a specific id.

    Register remote typed actor by a specific id.

    id

    custom actor id

    Definition Classes
    RemoteServerModule
  52. def registerTypedPerSessionActor (intfClass: Class[_], factory: Creator[AnyRef]): Unit

    Register typed actor by interface name.

    Register typed actor by interface name. Java API

    Definition Classes
    RemoteServerModule
  53. def registerTypedPerSessionActor (intfClass: Class[_], factory: ⇒ AnyRef): Unit

    Register typed actor by interface name.

    Register typed actor by interface name.

    Definition Classes
    RemoteServerModule
  54. def removeListener (listener: ActorRef): Unit

    Removes the listener this this registry's listener list.

    Removes the listener this this registry's listener list. The listener is stopped by this method if manageLifeCycleOfListeners yields true.

    Definition Classes
    ListenerManagement
  55. def restartClientConnection (address: InetSocketAddress): Boolean

    Restarts a specific client connected to the supplied remote address, but only if the client is not shut down

    Restarts a specific client connected to the supplied remote address, but only if the client is not shut down

    Definition Classes
    NettyRemoteClientModuleRemoteClientModule
  56. def send [T] (message: Any, senderOption: Option[ActorRef], senderFuture: Option[CompletableFuture[T]], remoteAddress: InetSocketAddress, timeout: Long, isOneWay: Boolean, actorRef: ActorRef, typedActorInfo: Option[(String, String)], actorType: ActorType, loader: Option[ClassLoader]): Option[CompletableFuture[T]]

    Attributes
    protected[akka]
    Definition Classes
    NettyRemoteClientModuleRemoteClientModule
  57. def shutdown (): Unit

    Definition Classes
    RemoteSupport
  58. def shutdownClientConnection (address: InetSocketAddress): Boolean

    Shuts down a specific client connected to the supplied remote address returns true if successful

    Shuts down a specific client connected to the supplied remote address returns true if successful

    Definition Classes
    NettyRemoteClientModuleRemoteClientModule
  59. def shutdownClientModule (): Unit

    Clean-up all open connections.

    Clean-up all open connections.

    Definition Classes
    NettyRemoteClientModuleRemoteClientModule
  60. def shutdownRemoteClients (): Unit

    Definition Classes
    NettyRemoteClientModule
  61. def shutdownServerModule (): Unit

    Shuts the server down

    Shuts the server down

    Definition Classes
    NettyRemoteServerModuleRemoteServerModule
  62. def start (_hostname: String, _port: Int, loader: Option[ClassLoader] = None): RemoteServerModule

    Starts the server up

    Starts the server up

    Definition Classes
    NettyRemoteServerModuleRemoteServerModule
  63. def start (host: String, port: Int, loader: ClassLoader): RemoteServerModule

    Starts the server up

    Starts the server up

    Definition Classes
    RemoteServerModule
  64. def start (host: String, port: Int): RemoteServerModule

    Starts the server up

    Starts the server up

    Definition Classes
    RemoteServerModule
  65. def start (loader: ClassLoader): RemoteServerModule

    Starts the server up

    Starts the server up

    Definition Classes
    RemoteServerModule
  66. def start (): RemoteServerModule

    Starts the server up

    Starts the server up

    Definition Classes
    RemoteServerModule
  67. def synchronized [T0] (arg0: ⇒ T0): T0

    Attributes
    final
    Definition Classes
    AnyRef
  68. def toString (): String

    Definition Classes
    AnyRef → Any
  69. def typedActorFor [T] (intfClass: Class[T], serviceId: String, implClassName: String, timeout: Long, hostname: String, port: Int, loader: Option[ClassLoader]): T

    Methods that needs to be implemented by a transport *

    Methods that needs to be implemented by a transport *

    Attributes
    protected[akka]
    Definition Classes
    NettyRemoteClientModuleRemoteClientModule
  70. def typedActorFor [T] (intfClass: Class[T], serviceId: String, implClassName: String, timeout: Long, hostname: String, port: Int, loader: ClassLoader): T

    Definition Classes
    RemoteClientModule
  71. def typedActorFor [T] (intfClass: Class[T], serviceIdOrClassName: String, timeout: Long, hostname: String, port: Int, loader: ClassLoader): T

    Definition Classes
    RemoteClientModule
  72. def typedActorFor [T] (intfClass: Class[T], serviceIdOrClassName: String, timeout: Long, hostname: String, port: Int): T

    Definition Classes
    RemoteClientModule
  73. def typedActorFor [T] (intfClass: Class[T], serviceIdOrClassName: String, hostname: String, port: Int): T

    Definition Classes
    RemoteClientModule
  74. def unregister (id: String): Unit

    Unregister Remote Actor by specific 'id'.

    Unregister Remote Actor by specific 'id'.

    NOTE: You need to call this method if you have registered an actor by a custom ID.

    Definition Classes
    NettyRemoteServerModuleRemoteServerModule
  75. def unregister (actorRef: ActorRef): Unit

    Unregister Remote Actor that is registered using its 'id' field (not custom ID).

    Unregister Remote Actor that is registered using its 'id' field (not custom ID).

    Definition Classes
    NettyRemoteServerModuleRemoteServerModule
  76. def unregisterPerSession (id: String): Unit

    Unregister Remote Actor by specific 'id'.

    Unregister Remote Actor by specific 'id'.

    NOTE: You need to call this method if you have registered an actor by a custom ID.

    Definition Classes
    NettyRemoteServerModuleRemoteServerModule
  77. def unregisterTypedActor (id: String): Unit

    Unregister Remote Typed Actor by specific 'id'.

    Unregister Remote Typed Actor by specific 'id'.

    NOTE: You need to call this method if you have registered an actor by a custom ID.

    Definition Classes
    NettyRemoteServerModuleRemoteServerModule
  78. def unregisterTypedPerSessionActor (id: String): Unit

    Unregister Remote Typed Actor by specific 'id'.

    Unregister Remote Typed Actor by specific 'id'.

    NOTE: You need to call this method if you have registered an actor by a custom ID.

    Definition Classes
    NettyRemoteServerModuleRemoteServerModule
  79. def wait (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()
  80. def wait (arg0: Long, arg1: Int): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()
  81. def wait (arg0: Long): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()
  82. def actorOf [T <: Actor] (host: String, port: Int)(implicit arg0: Manifest[T]): ActorRef

    Creates a Client-managed ActorRef out of the Actor of the specified Class.

    Creates a Client-managed ActorRef out of the Actor of the specified Class. If the supplied host and port is identical of the configured local node, it will be a local actor

      import Actor._
      val actor = actorOf[MyActor]("www.akka.io",2552)
      actor.start()
      actor ! message
      actor.stop()
    
    You can create and start the actor in one statement like this:
      val actor = actorOf[MyActor]("www.akka.io",2552).start()
    

    Definition Classes
    RemoteSupport
    Annotations
    @deprecated
    Deprecated

    Will be removed after 1.1

  83. def actorOf (clazz: Class[_ <: akka.actor.Actor], host: String, port: Int): ActorRef

    Creates a Client-managed ActorRef out of the Actor of the specified Class.

    Creates a Client-managed ActorRef out of the Actor of the specified Class. If the supplied host and port is identical of the configured local node, it will be a local actor

      import Actor._
      val actor = actorOf(classOf[MyActor],"www.akka.io",2552)
      actor.start()
      actor ! message
      actor.stop()
    
    You can create and start the actor in one statement like this:
      val actor = actorOf(classOf[MyActor],"www.akka.io",2552).start()
    

    Definition Classes
    RemoteSupport
    Annotations
    @deprecated
    Deprecated

    Will be removed after 1.1

  84. def actorOf (factory: ⇒ Actor, host: String, port: Int): ActorRef

    Creates a Client-managed ActorRef out of the Actor of the specified Class.

    Creates a Client-managed ActorRef out of the Actor of the specified Class. If the supplied host and port is identical of the configured local node, it will be a local actor

      import Actor._
      val actor = actorOf(classOf[MyActor],"www.akka.io", 2552)
      actor.start()
      actor ! message
      actor.stop()
    
    You can create and start the actor in one statement like this:
      val actor = actorOf(classOf[MyActor],"www.akka.io", 2552).start()
    

    Definition Classes
    RemoteSupport
    Annotations
    @deprecated
    Deprecated

    Will be removed after 1.1

Inherited from NettyRemoteClientModule

Inherited from NettyRemoteServerModule

Inherited from RemoteSupport

Inherited from RemoteClientModule

Inherited from RemoteServerModule

Inherited from RemoteModule

Inherited from ListenerManagement

Inherited from AnyRef

Inherited from Any