akka.remote.netty

ActiveRemoteClient

class ActiveRemoteClient extends RemoteClient

RemoteClient represents a connection to an Akka node. Is used to send messages to remote actors on the node.

Linear Supertypes
RemoteClient, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Hide All
  2. Show all
  1. ActiveRemoteClient
  2. RemoteClient
  3. AnyRef
  4. Any
Visibility
  1. Public
  2. All

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. def asInstanceOf [T0] : T0

    Attributes
    final
    Definition Classes
    Any

  7. def clone (): AnyRef

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()

  8. def connect (reconnectIfAlreadyConnected: Boolean = false): Boolean

    Definition Classes
    ActiveRemoteClient → RemoteClient

  9. def currentChannel : Channel

    Definition Classes
    ActiveRemoteClient → RemoteClient

  10. def eq (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef

  11. def equals (arg0: Any): Boolean

    Definition Classes
    AnyRef → Any

  12. def finalize (): Unit

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()

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

    Attributes
    protected
    Definition Classes
    RemoteClient

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

    Attributes
    final
    Definition Classes
    AnyRef

  15. def hashCode (): Int

    Definition Classes
    AnyRef → Any

  16. def isInstanceOf [T0] : Boolean

    Attributes
    final
    Definition Classes
    Any

  17. val loader : Option[ClassLoader]

  18. val name : String

    Definition Classes
    RemoteClient

  19. def ne (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef

  20. def notify (): Unit

    Attributes
    final
    Definition Classes
    AnyRef

  21. def notifyAll (): Unit

    Attributes
    final
    Definition Classes
    AnyRef

  22. def notifyListeners (msg: ⇒ Any): Unit

    Definition Classes
    ActiveRemoteClient → RemoteClient

  23. def pendingMessages : Array[Any]

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

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

    Definition Classes
    RemoteClient

  24. val pendingRequests : AbstractQueue[(Boolean, Uuid, RemoteMessageProtocol)] with Serializable

    Attributes
    protected
    Definition Classes
    RemoteClient

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

    Sends the message across the wire

    Sends the message across the wire

    Definition Classes
    RemoteClient

  26. 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

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

    Definition Classes
    RemoteClient

  27. def shutdown (): Boolean

    Definition Classes
    ActiveRemoteClient → RemoteClient

  28. val supervisors : ConcurrentHashMap[Uuid, ActorRef]

    Attributes
    protected
    Definition Classes
    RemoteClient

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

    Attributes
    final
    Definition Classes
    AnyRef

  30. def toString (): String

    Definition Classes
    AnyRef → Any

  31. val transactionLogCapacity : Int

    Definition Classes
    RemoteClient

  32. val useTransactionLog : Boolean

    Definition Classes
    RemoteClient

  33. def wait (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()

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

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()

  35. def wait (arg0: Long): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()

Inherited from RemoteClient

Inherited from AnyRef

Inherited from Any