NettyRemoteClientModule

def actorFor (serviceId: String, className: String, timeout: Long, hostname: String, port: Int, loader: Option[ClassLoader]): ActorRef

def isRunning : Boolean

def optimizeLocalScoped_? (): Boolean

def clientManagedActorOf (factory: () ⇒ Actor, host: String, port: Int): ActorRef

def != (arg0: AnyRef): Boolean

def != (arg0: Any): Boolean

def ## (): Int

def == (arg0: AnyRef): Boolean

def == (arg0: Any): Boolean

val UUID_PREFIX : String

def actorFor (serviceId: String, className: String, timeout: Long, hostname: String, port: Int): ActorRef

def actorFor (classNameOrServiceId: String, timeout: Long, hostname: String, port: Int, loader: ClassLoader): ActorRef

def actorFor (classNameOrServiceId: String, timeout: Long, hostname: String, port: Int): ActorRef

def actorFor (serviceId: String, className: String, hostname: String, port: Int, loader: ClassLoader): ActorRef

def actorFor (serviceId: String, className: String, hostname: String, port: Int): ActorRef

def actorFor (classNameOrServiceId: String, hostname: String, port: Int, loader: ClassLoader): ActorRef

def actorFor (classNameOrServiceId: String, hostname: String, port: Int): ActorRef

def asInstanceOf [T0] : T0

def clone (): AnyRef

def eq (arg0: AnyRef): Boolean

def equals (arg0: Any): Boolean

def finalize (): Unit

val futures : ConcurrentHashMap[Uuid, akka.dispatch.CompletableFuture[_]]

def getClass (): java.lang.Class[_]

def hashCode (): Int

def isInstanceOf [T0] : Boolean

def ne (arg0: AnyRef): Boolean

def notify (): Unit

def notifyAll (): Unit

def registerClientManagedActor (hostname: String, port: Int, uuid: Uuid): Unit

def restartClientConnection (address: InetSocketAddress): Boolean

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

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]]

def shutdownClientConnection (address: InetSocketAddress): Boolean

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

def shutdownClientModule (): Unit

Clean-up all open connections.

def shutdownRemoteClients (): Unit

def synchronized [T0] (arg0: ⇒ T0): T0

var timer : HashedWheelTimer

def toString (): String

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 *

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], serviceIdOrClassName: String, timeout: Long, hostname: String, port: Int, loader: ClassLoader): T

def typedActorFor [T] (intfClass: Class[T], serviceIdOrClassName: String, timeout: Long, hostname: String, port: Int): T

def typedActorFor [T] (intfClass: Class[T], serviceIdOrClassName: String, hostname: String, port: Int): T

def wait (): Unit

def wait (arg0: Long, arg1: Int): Unit

def wait (arg0: Long): Unit

def addListener (listener: ActorRef): Unit

def foreachListener (f: (ActorRef) ⇒ Unit): Unit

def hasListener (listener: ActorRef): Boolean

def hasListeners : Boolean

def notifyListeners (message: ⇒ Any): Unit

def removeListener (listener: ActorRef): Unit