RemoteClient

def connect (reconnectIfAlreadyConnected: Boolean = false): Boolean

def currentChannel : Channel

def loader : Option[ClassLoader]

def notifyListeners (msg: ⇒ Any): Unit

def shutdown (): Boolean

def != (arg0: AnyRef): Boolean

def != (arg0: Any): Boolean

def ## (): Int

def == (arg0: AnyRef): Boolean

def == (arg0: Any): Boolean

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

val module : NettyRemoteClientModule

val name : String

def ne (arg0: AnyRef): Boolean

def notify (): Unit

def notifyAll (): Unit

def pendingMessages : Array[Any]

Returns an array with the current pending messages not yet delivered.

val remoteAddress : InetSocketAddress

val resendMessageQueue : Queue[RemoteMessageProtocol]

val resendMessageQueueLock : SimpleLock

val resendMessagesOnFailure : Boolean

val resendMessagesOnFailureCapacity : Int

def send [T] (request: RemoteMessageProtocol, senderFuture: Option[CompletableFuture[T]]): Option[CompletableFuture[T]]

Sends the message across the wire

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): Option[CompletableFuture[T]]

Converts the message to the wireprotocol and sends the message across the wire

val supervisors : ConcurrentHashMap[Uuid, ActorRef]

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

def toString (): String

def wait (): Unit

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

def wait (arg0: Long): Unit